17 #ifndef JUBATUS_CORE_FRAMEWORK_MIXABLE_VERSIONED_TABLE_HPP_
18 #define JUBATUS_CORE_FRAMEWORK_MIXABLE_VERSIONED_TABLE_HPP_
23 #include "../common/version.hpp"
24 #include "../framework/push_mixable.hpp"
25 #include "../framework/linear_mixable.hpp"
26 #include "../storage/column_table.hpp"
27 #include "../unlearner/unlearner_base.hpp"
38 typedef jubatus::util::lang::shared_ptr<storage::column_table>
model_ptr;
41 jubatus::util::lang::shared_ptr<unlearner::unlearner_base>
unlearner) {
54 void push(
const msgpack::object& diff);
77 jubatus::util::lang::shared_ptr<unlearner::unlearner_base>
unlearner_;
85 #endif // JUBATUS_CORE_FRAMEWORK_MIXABLE_VERSIONED_TABLE_HPP_
bool put_diff(const framework::diff_object &obj)
model_ptr get_model() const
void get_diff(framework::packer &) const
jubatus::util::lang::shared_ptr< diff_object_raw > diff_object
void pull_impl(const version_clock &vc, framework::packer &) const
void push_impl(const msgpack::object &)
jubatus::util::data::optional< std::string > unlearner
void update_version(const storage::column_table::version_t &version)
void get_argument(framework::packer &pk) const
jubatus::util::lang::shared_ptr< unlearner::unlearner_base > unlearner_
void pull(const msgpack::object &arg, framework::packer &pk) const
void set_model(model_ptr m)
std::pair< owner, uint64_t > version_t
jubatus::util::lang::shared_ptr< storage::column_table > model_ptr
framework::diff_object convert_diff_object(const msgpack::object &) const
void set_unlearner(jubatus::util::lang::shared_ptr< unlearner::unlearner_base > unlearner)
storage::version get_version() const
void mix(const msgpack::object &obj, framework::diff_object) const
std::map< storage::owner, uint64_t > version_clock
void push(const msgpack::object &diff)