17 #ifndef JUBATUS_CORE_BURST_AGGREGATOR_HPP_
18 #define JUBATUS_CORE_BURST_AGGREGATOR_HPP_
21 #include "jubatus/util/lang/scoped_ptr.h"
24 #include "../framework/mixable_helper.hpp"
32 aggregator(
int window_batch_size,
double batch_interval,
int max_stored);
44 double costcut_threshold,
45 int max_reuse_batches,
49 void unpack(msgpack::object o);
53 jubatus::util::lang::scoped_ptr<impl_>
p_;
60 #endif // JUBATUS_CORE_BURST_AGGREGATOR_HPP_
void unpack(msgpack::object o)
jubatus::util::lang::scoped_ptr< impl_ > p_
int flush_results(double scaling_param, double gamma, double costcut_threshold, int max_reuse_batches, result_storage &stored)
void pack(framework::packer &packer) const
aggregator(int window_batch_size, double batch_interval, int max_stored)
msgpack::packer< jubatus_packer > packer
bool add_document(int d, int r, double pos)