27 namespace clustering {
30 const std::string& name,
38 jubatus::util::lang::shared_ptr<compressor::compressor> compressor) {
59 for (std::vector<wplist>::const_iterator it =
mine_.begin();
60 it !=
mine_.end(); ++it) {
68 typedef wplist::iterator iter;
69 for (iter it = points.begin(); it != points.end(); ++it) {
77 if (std::exp(-lam * bucket_number) < C) {
89 if (r >=
mine_.size() - 1) {
106 mine_[r + 1].clear();
111 dstsize,
mine_[r + 1]);
117 packer.pack_array(4);
125 std::vector<msgpack::object> mems;
127 if (mems.size() != 4) {
128 throw msgpack::type_error();
131 mems[1].convert(&
mine_);
double forgetting_threshold
void forget_weight(wplist &points)
char digit(int num, int r, int n)
bool reach_forgetting_threshold(size_t bucket_number)
bool is_next_bucket_full(size_t bucket_number)
void pack_impl_(framework::packer &packer) const
jubatus::util::lang::shared_ptr< compressor::compressor > compressor_
void concat(const wplist &src, wplist &dst)
int compressed_bucket_size
virtual void clear_impl_()
msgpack::packer< jubatus_packer > packer
void unpack_impl_(msgpack::object o)
virtual void unpack_impl_(msgpack::object o)
void set_compressor(jubatus::util::lang::shared_ptr< compressor::compressor > compressor)
virtual void pack_impl_(framework::packer &packer) const
compressive_storage(const std::string &name, const clustering_config &config)
std::vector< weighted_point > wplist
void increment_revision()
std::vector< wplist > mine_
void add(const weighted_point &point)
clustering_config config_