26 namespace clustering {
43 for (diff_t::const_iterator it =
common_.begin();
53 d.push_back(make_pair(
name_, coreset));
58 for (diff_t::const_iterator it = diff.begin(); it != diff.end(); ++it) {
59 if (it->first !=
name_) {
70 diff_t::const_iterator lb = lhs.begin(), le = lhs.end();
71 diff_t::iterator b = ret.begin(), e = ret.end();
72 while (lb != le && b != e) {
73 if ((*lb).first < (*b).first) {
74 b = ret.insert(b, (*lb));
76 }
else if ((*lb).first > (*b).first) {
79 std::copy((*lb).second.begin(), (*lb).second.end(),
80 std::back_inserter((*b).second));
85 std::copy(lb, le, std::back_inserter(ret));
virtual wplist get_common() const
void unpack(msgpack::object o)
virtual wplist get_all() const
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 concat(const wplist &src, wplist &dst)
void dispatch(const storage_event_type &type, const wplist &data) const
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 unpack_impl_(msgpack::object o)
virtual void pack_impl_(framework::packer &packer) const
std::vector< weighted_point > wplist
void increment_revision()
bool put_diff(const diff_t &d)