jubatus::core::burst::aggregator Class Reference

#include <aggregator.hpp>

Collaboration diagram for jubatus::core::burst::aggregator:

Classes
class	impl_

Public Member Functions
bool	add_document (int d, int r, double pos)
	aggregator (int window_batch_size, double batch_interval, int max_stored)
int	flush_results (double scaling_param, double gamma, double costcut_threshold, int max_reuse_batches, result_storage &stored)
void	pack (framework::packer &packer) const
void	unpack (msgpack::object o)
	~aggregator ()

Private Attributes
jubatus::util::lang::scoped_ptr< impl_ >	p_

Detailed Description

Definition at line 30 of file aggregator.hpp.

Constructor & Destructor Documentation

jubatus::core::burst::aggregator::aggregator	(	int	window_batch_size,
		double	batch_interval,
		int	max_stored
	)

Definition at line 137 of file aggregator.cpp.

    : p_(new impl_(window_batch_size, batch_interval, max_stored)) {
}

jubatus::core::burst::aggregator::~aggregator

(

)

Definition at line 142 of file aggregator.cpp.

                        {
}

Member Function Documentation

bool jubatus::core::burst::aggregator::add_document	(	int	d,
		int	r,
		double	pos
	)

Definition at line 145 of file aggregator.cpp.

References JUBATUS_ASSERT, and p_.

                                                      {
  JUBATUS_ASSERT(p_);
  return p_->add_document(d, r, pos);
}

int jubatus::core::burst::aggregator::flush_results	(	double	scaling_param,
		double	gamma,
		double	costcut_threshold,
		int	max_reuse_batches,
		result_storage &	stored
	)

Definition at line 150 of file aggregator.cpp.

References JUBATUS_ASSERT, and p_.

                                                      {
  JUBATUS_ASSERT(p_);
  return p_->flush_results(scaling_param, gamma, costcut_threshold,
                           max_reuse_batches, stored);
}

void jubatus::core::burst::aggregator::pack

(

framework::packer &

packer

)

const

Definition at line 160 of file aggregator.cpp.

References JUBATUS_ASSERT, and p_.

                                                   {
  JUBATUS_ASSERT(p_);
  packer.pack(*p_);
}

void jubatus::core::burst::aggregator::unpack

(

msgpack::object

o

)

Definition at line 165 of file aggregator.cpp.

References JUBATUS_ASSERT, and p_.

                                       {
  JUBATUS_ASSERT(p_);
  o.convert(p_.get());
}

Member Data Documentation

jubatus::util::lang::scoped_ptr<impl_> jubatus::core::burst::aggregator::p_

private

Definition at line 52 of file aggregator.hpp.

Referenced by add_document(), flush_results(), pack(), and unpack().

---

The documentation for this class was generated from the following files:

• jubatus/core/burst/aggregator.hpp
• jubatus/core/burst/aggregator.cpp