23 #include "../fv_converter/datum.hpp"
24 #include "../fv_converter/datum_to_fv_converter.hpp"
25 #include "../fv_converter/converter_config.hpp"
26 #include "../regression/regression_base.hpp"
27 #include "../storage/storage_factory.hpp"
31 using jubatus::util::lang::shared_ptr;
40 shared_ptr<storage::storage_base> model_storage,
41 shared_ptr<core::regression::regression_base> regression_method,
42 shared_ptr<fv_converter::datum_to_fv_converter> converter)
43 : converter_(converter)
44 , regression_(regression_method)
45 , mixable_regression_model_(regression_method->get_storage())
58 converter_->convert_and_update_weight(data.second, v);
86 if (o.type != msgpack::type::ARRAY || o.via.array.size != 2) {
87 throw msgpack::type_error();
93 regression_->get_storage()->unpack(o.via.array.ptr[0]);
jubatus::util::lang::shared_ptr< jubatus::core::regression::regression_base > regression_
model_ptr get_model() const
float estimate(const fv_converter::datum &data) const
void train(const std::pair< float, fv_converter::datum > &data)
fv_converter::mixable_weight_manager wm_
regression(jubatus::util::lang::shared_ptr< storage::storage_base > model_storage, jubatus::util::lang::shared_ptr< regression_base > regression_method, jubatus::util::lang::shared_ptr< fv_converter::datum_to_fv_converter > converter)
void pack(framework::packer &pk) const
void get_status(std::map< std::string, std::string > &status) const
framework::linear_mixable_helper< weight_manager, versioned_weight_diff > mixable_weight_manager
void unpack(msgpack::object o)
framework::linear_function_mixer mixable_regression_model_
std::vector< std::pair< std::string, float > > sfv_t
jubatus::util::lang::shared_ptr< fv_converter::datum_to_fv_converter > converter_
void register_mixable(framework::mixable *mixable)
storage::mixable_lsh_index_storage::model_ptr model_ptr