17 #ifndef JUBATUS_CORE_CLUSTERING_COMPRESSIVE_STORAGE_HPP_
18 #define JUBATUS_CORE_CLUSTERING_COMPRESSIVE_STORAGE_HPP_
22 #include <msgpack.hpp>
27 namespace clustering {
39 jubatus::util::lang::shared_ptr<compressor::compressor> compressor);
53 jubatus::util::lang::shared_ptr<compressor::compressor>
compressor_;
60 #endif // JUBATUS_CORE_CLUSTERING_COMPRESSIVE_STORAGE_HPP_
void forget_weight(wplist &points)
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_
msgpack::packer< jubatus_packer > packer
void unpack_impl_(msgpack::object o)
void set_compressor(jubatus::util::lang::shared_ptr< compressor::compressor > compressor)
compressive_storage(const std::string &name, const clustering_config &config)
std::vector< weighted_point > wplist
std::vector< wplist > mine_
void add(const weighted_point &point)