jubatus::core::burst::burst::impl_::aggregate_helper_ Class Reference

Collaboration diagram for jubatus::core::burst::burst::impl_::aggregate_helper_:

Public Member Functions
bool	add_document (int d, int r, double pos) const
	aggregate_helper_ (const burst_options &options, const storage_ &s)
void	calculate_result (const burst_options &options) const
const shared_ptr< aggregator > &	get_aggregator () const
diff_t::impl_::entry_t	get_diff () const
const keyword_params &	get_params () const
const shared_ptr< result_storage > &	get_storage () const
bool	is_to_be_removed () const
void	set_processed ()
void	set_unprocessed ()
void	tick_removal_count ()

Private Attributes
shared_ptr< aggregator >	a_
keyword_params	params_
int	removal_count_
shared_ptr< result_storage >	s_

Detailed Description

Definition at line 102 of file burst.cpp.

Constructor & Destructor Documentation

jubatus::core::burst::burst::impl_::aggregate_helper_::aggregate_helper_ ( const burst_options &  options, const storage_ &  s  )

inline

Definition at line 104 of file burst.cpp.

        : a_(new aggregator(options.window_batch_size,
                            options.batch_interval,
                            options.result_window_rotate_size)),
          s_(s.get_storage()),
          params_(s.get_params()),
          removal_count_(-1) {
    }

Member Function Documentation

bool jubatus::core::burst::burst::impl_::aggregate_helper_::add_document ( int  d, int  r, double  pos  ) const

inline

Definition at line 114 of file burst.cpp.

References a_.

Referenced by jubatus::core::burst::burst::impl_::add_document().

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

Here is the caller graph for this function:

void jubatus::core::burst::burst::impl_::aggregate_helper_::calculate_result ( const burst_options &  options ) const

inline

Definition at line 118 of file burst.cpp.

References a_, jubatus::core::burst::burst_options::costcut_threshold, jubatus::core::burst::keyword_params::gamma, jubatus::core::burst::burst_options::max_reuse_batch_num, params_, s_, and jubatus::core::burst::keyword_params::scaling_param.

                                                              {
      a_->flush_results(params_.scaling_param,
                        params_.gamma,
                        options.costcut_threshold,
                        options.max_reuse_batch_num,
                        *s_);
    }

const shared_ptr<aggregator>& jubatus::core::burst::burst::impl_::aggregate_helper_::get_aggregator ( ) const

inline

Definition at line 133 of file burst.cpp.

References a_.

Referenced by jubatus::core::burst::burst::impl_::unpack_impl_().

                                                         {
      return a_;
    }

Here is the caller graph for this function:

diff_t::impl_::entry_t jubatus::core::burst::burst::impl_::aggregate_helper_::get_diff ( ) const

inline

Definition at line 126 of file burst.cpp.

References jubatus::core::burst::burst::diff_t::impl_::entry_t::params, params_, jubatus::core::burst::burst::diff_t::impl_::entry_t::results, and s_.

                                        {
      diff_t::impl_::entry_t entry;
      entry.params = params_;
      entry.results = s_->get_diff();
      return entry;
    }

const keyword_params& jubatus::core::burst::burst::impl_::aggregate_helper_::get_params ( ) const

inline

Definition at line 141 of file burst.cpp.

References params_.

                                             {
      return params_;
    }

const shared_ptr<result_storage>& jubatus::core::burst::burst::impl_::aggregate_helper_::get_storage ( ) const

inline

Definition at line 137 of file burst.cpp.

References s_.

                                                          {
      return s_;
    }

bool jubatus::core::burst::burst::impl_::aggregate_helper_::is_to_be_removed ( ) const

inline

Definition at line 161 of file burst.cpp.

References removal_count_.

                                  {
      return removal_count_ == 0;
    }

void jubatus::core::burst::burst::impl_::aggregate_helper_::set_processed ( )

inline

Definition at line 151 of file burst.cpp.

References removal_count_.

                         {
      removal_count_ = -1;
    }

void jubatus::core::burst::burst::impl_::aggregate_helper_::set_unprocessed ( )

inline

Definition at line 145 of file burst.cpp.

References removal_count_, and jubatus::core::burst::survival_mix_count_from_set_unprocessed.

                           {
      if (removal_count_ < 0) {
        removal_count_ = survival_mix_count_from_set_unprocessed;
      }
    }

void jubatus::core::burst::burst::impl_::aggregate_helper_::tick_removal_count ( )

inline

Definition at line 155 of file burst.cpp.

References removal_count_.

                              {
      if (removal_count_ > 0) {
        --removal_count_;
      }
    }

Member Data Documentation

shared_ptr<aggregator> jubatus::core::burst::burst::impl_::aggregate_helper_::a_

private

Definition at line 166 of file burst.cpp.

Referenced by add_document(), calculate_result(), and get_aggregator().

keyword_params jubatus::core::burst::burst::impl_::aggregate_helper_::params_

private

Definition at line 168 of file burst.cpp.

Referenced by calculate_result(), get_diff(), and get_params().

int jubatus::core::burst::burst::impl_::aggregate_helper_::removal_count_

private

Definition at line 169 of file burst.cpp.

Referenced by is_to_be_removed(), set_processed(), set_unprocessed(), and tick_removal_count().

shared_ptr<result_storage> jubatus::core::burst::burst::impl_::aggregate_helper_::s_

private

Definition at line 167 of file burst.cpp.

Referenced by calculate_result(), get_diff(), and get_storage().

---

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

• jubatus/core/burst/burst.cpp