17 #ifndef JUBATUS_CORE_CLUSTERING_CLUSTERING_HPP_
18 #define JUBATUS_CORE_CLUSTERING_CLUSTERING_HPP_
25 #include "jubatus/util/concurrent/rwmutex.h"
26 #include "jubatus/util/data/unordered_map.h"
27 #include "jubatus/util/lang/shared_ptr.h"
28 #include "../common/exception.hpp"
29 #include "../common/type.hpp"
30 #include "../framework/mixable.hpp"
38 namespace clustering {
50 const std::string& name,
55 bool push(
const std::vector<weighted_point>& points);
65 jubatus::util::lang::shared_ptr<storage>
get_storage();
71 std::string
type()
const;
74 void unpack(msgpack::object o);
90 jubatus::util::lang::shared_ptr<mixable_storage>
storage_;
97 #endif // JUBATUS_CORE_CLUSTERING_CLUSTERING_HPP_
std::vector< wplist > get_core_members() const
wplist get_coreset() const
clustering_error(const std::string &msg)
jubatus::util::lang::shared_ptr< storage > get_storage()
void set_storage(jubatus::util::lang::shared_ptr< storage > storage)
common::sfv_t get_nearest_center(const common::sfv_t &point) const
clustering(const std::string &name, const std::string &method, const clustering_config &cfg)
wplist get_nearest_members(const common::sfv_t &point) const
void pack(framework::packer &pk) const
std::vector< common::sfv_t > get_k_center() const
void unpack(msgpack::object o)
runtime_error(const std::string &what)
clustering_config config_
jubatus::util::lang::shared_ptr< clustering_method > clustering_method_
void update_clusters(const wplist &points, bool batch)
void set_clustering_method(jubatus::util::lang::shared_ptr< clustering_method > clustering_method)
wplist get_coreset_mine() const
std::vector< std::pair< std::string, float > > sfv_t
jubatus::util::lang::shared_ptr< mixable_storage > storage_
std::vector< weighted_point > wplist
bool push(const std::vector< weighted_point > &points)
framework::mixable * get_mixable() const
size_t get_revision() const