17 #ifndef JUBATUS_CORE_CLUSTERING_STORAGE_HPP_
18 #define JUBATUS_CORE_CLUSTERING_STORAGE_HPP_
23 #include <msgpack.hpp>
24 #include "../framework/mixable_helper.hpp"
25 #include "../common/version.hpp"
32 namespace clustering {
61 void unpack(msgpack::object o);
76 std::vector<std::pair<std::string, wplist> >
common_;
85 #endif // JUBATUS_CORE_CLUSTERING_STORAGE_HPP_
virtual wplist get_common() const
void unpack(msgpack::object o)
virtual wplist get_all() const
framework::linear_mixable_helper< storage, diff_t > mixable_storage
void mix(const diff_t &, diff_t &ret)
std::vector< std::pair< std::string, wplist > > common_
storage(const std::string &name, const clustering_config &config)
void pack(framework::packer &packer) const
void get_diff(diff_t &d) const
virtual void clear_impl_()
virtual wplist get_mine() const =0
msgpack::packer< jubatus_packer > packer
std::vector< std::pair< std::string, wplist > > diff_t
virtual void add(const weighted_point &point)=0
core::storage::version get_version() const
virtual void unpack_impl_(msgpack::object o)
virtual void pack_impl_(framework::packer &packer) const
std::vector< weighted_point > wplist
void increment_revision()
MSGPACK_DEFINE(revision_, name_, config_, common_)
bool put_diff(const diff_t &d)
clustering_config config_