jubatus::core::common::portable_mixer< Storage, Diff > Class Template Reference

#include <portable_mixer.hpp>

Collaboration diagram for jubatus::core::common::portable_mixer< Storage, Diff >:

Public Member Functions
void	add (Storage *storage)
void	clear ()
Storage *	get_hash (const std::string &id) const
Storage *	get_random ()
void	mix ()
	portable_mixer ()
	portable_mixer (uint32_t seed)

Private Attributes
jubatus::util::math::random::mtrand	rand_
std::vector< Storage * >	storages_

Detailed Description

template<typename Storage, typename Diff = std::string>
class jubatus::core::common::portable_mixer< Storage, Diff >

Definition at line 30 of file portable_mixer.hpp.

Constructor & Destructor Documentation

template<typename Storage , typename Diff = std::string>

jubatus::core::common::portable_mixer< Storage, Diff >::portable_mixer ( )

inline

Definition at line 32 of file portable_mixer.hpp.

                   {
  }

template<typename Storage , typename Diff = std::string>

jubatus::core::common::portable_mixer< Storage, Diff >::portable_mixer ( uint32_t  seed )

inlineexplicit

Definition at line 35 of file portable_mixer.hpp.

      : rand_(seed) {
  }

Member Function Documentation

template<typename Storage , typename Diff = std::string>

void jubatus::core::common::portable_mixer< Storage, Diff >::add ( Storage *  storage )

inline

Definition at line 43 of file portable_mixer.hpp.

References jubatus::core::common::portable_mixer< Storage, Diff >::storages_.

                             {
    storages_.push_back(storage);
  }

template<typename Storage , typename Diff = std::string>

void jubatus::core::common::portable_mixer< Storage, Diff >::clear ( )

inline

Definition at line 39 of file portable_mixer.hpp.

References jubatus::core::common::portable_mixer< Storage, Diff >::storages_.

               {
    storages_.clear();
  }

template<typename Storage , typename Diff = std::string>

Storage* jubatus::core::common::portable_mixer< Storage, Diff >::get_hash ( const std::string &  id ) const

inline

Definition at line 51 of file portable_mixer.hpp.

References jubatus::core::common::hash_util::calc_string_hash(), and jubatus::core::common::portable_mixer< Storage, Diff >::storages_.

                                               {
    return storages_[hash_util::calc_string_hash(id) % storages_.size()];
  }

Here is the call graph for this function:

template<typename Storage , typename Diff = std::string>

Storage* jubatus::core::common::portable_mixer< Storage, Diff >::get_random ( )

inline

Definition at line 47 of file portable_mixer.hpp.

References jubatus::core::common::portable_mixer< Storage, Diff >::rand_, and jubatus::core::common::portable_mixer< Storage, Diff >::storages_.

                        {
    return storages_[rand_(storages_.size())];
  }

template<typename Storage , typename Diff = std::string>

void jubatus::core::common::portable_mixer< Storage, Diff >::mix ( )

inline

Definition at line 55 of file portable_mixer.hpp.

References jubatus::core::common::portable_mixer< Storage, Diff >::storages_.

             {
    if (storages_.empty()) {
      return;
    }

    Diff mixed;
    storages_[0]->get_diff(mixed);

    for (size_t i = 1; i < storages_.size(); ++i) {
      Diff diff;
      storages_[i]->get_diff(diff);
      storages_[0]->mix(diff, mixed);
    }

    for (size_t i = 0; i < storages_.size(); ++i) {
      storages_[i]->put_diff(mixed);
    }
  }

Member Data Documentation

template<typename Storage , typename Diff = std::string>

jubatus::util::math::random::mtrand jubatus::core::common::portable_mixer< Storage, Diff >::rand_

private

Definition at line 76 of file portable_mixer.hpp.

Referenced by jubatus::core::common::portable_mixer< Storage, Diff >::get_random().

template<typename Storage , typename Diff = std::string>

std::vector<Storage*> jubatus::core::common::portable_mixer< Storage, Diff >::storages_

private

Definition at line 75 of file portable_mixer.hpp.

Referenced by jubatus::core::common::portable_mixer< Storage, Diff >::add(), jubatus::core::common::portable_mixer< Storage, Diff >::clear(), jubatus::core::common::portable_mixer< Storage, Diff >::get_hash(), jubatus::core::common::portable_mixer< Storage, Diff >::get_random(), and jubatus::core::common::portable_mixer< Storage, Diff >::mix().

---

The documentation for this class was generated from the following file:

• jubatus/core/common/portable_mixer.hpp