#include <lof.hpp>

Inheritance diagram for jubatus::core::anomaly::lof:

Collaboration diagram for jubatus::core::anomaly::lof:

Public Member Functions
float	calc_anomaly_score (const common::sfv_t &query) const

float	calc_anomaly_score (const std::string &id) const

void	clear ()

void	clear_row (const std::string &id)

void	get_all_row_ids (std::vector< std::string > &ids) const

std::vector< framework::mixable * >	get_mixables () const

bool	is_updatable () const

	lof (const lof_storage::config &config, jubatus::util::lang::shared_ptr< core::recommender::recommender_base > nn_engine)

void	pack (framework::packer &packer) const

void	set_row (const std::string &id, const common::sfv_t &sfv)

std::string	type () const

void	unpack (msgpack::object o)

void	update_row (const std::string &id, const sfv_diff_t &diff)

	~lof ()

Public Member Functions inherited from jubatus::core::anomaly::anomaly_base
	anomaly_base ()

uint64_t	find_max_int_id () const

virtual	~anomaly_base ()

Public Member Functions inherited from jubatus::core::framework::model
virtual	~model ()

Private Attributes
jubatus::util::lang::shared_ptr< mixable_lof_storage >	mixable_storage_

jubatus::util::lang::shared_ptr< recommender::recommender_base >	nn_engine_

Detailed Description

Definition at line 31 of file lof.hpp.

Constructor & Destructor Documentation

jubatus::core::anomaly::lof::lof	(	const lof_storage::config &	config,
		jubatus::util::lang::shared_ptr< core::recommender::recommender_base >	nn_engine
	)

explicit

Definition at line 68 of file lof.cpp.

References JUBATUS_EXCEPTION, mixable_storage_, jubatus::core::anomaly::lof_storage::config::nearest_neighbor_num, and jubatus::core::anomaly::lof_storage::config::reverse_nearest_neighbor_num.

     : mixable_storage_(),
       nn_engine_(nn_engine) {
 
   if (!(2 <= config.nearest_neighbor_num)) {
     throw JUBATUS_EXCEPTION(
         common::invalid_parameter("2 <= nearest_neighbor_num"));
   }
 
   if (!(config.nearest_neighbor_num
       <= config.reverse_nearest_neighbor_num)) {
     throw JUBATUS_EXCEPTION(
         common::invalid_parameter(
             "nearest_neighbor_num <= reverse_nearest_neighbor_num"));
   }
 
   mixable_lof_storage::model_ptr p(new lof_storage(config, nn_engine));
   mixable_storage_.reset(new mixable_lof_storage(p));
 }

jubatus::core::anomaly::lof::~lof ( )

Definition at line 90 of file lof.cpp.

90 {

91 }

Member Function Documentation

float jubatus::core::anomaly::lof::calc_anomaly_score ( const common::sfv_t & query ) const

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 93 of file lof.cpp.

References mixable_storage_.

                                                             {
   unordered_map<string, float> neighbor_lrd;
   const float lrd = mixable_storage_->get_model()->collect_lrds(
       query, neighbor_lrd);
   return calculate_lof(lrd, neighbor_lrd);
 }

float jubatus::core::anomaly::lof::calc_anomaly_score ( const std::string & id ) const

virtual

Implements jubatus::core::anomaly::anomaly_base.

void jubatus::core::anomaly::lof::clear ( )

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 108 of file lof.cpp.

References mixable_storage_.

                 {
   mixable_storage_->get_model()->clear();
 }

void jubatus::core::anomaly::lof::clear_row ( const std::string & id )

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 112 of file lof.cpp.

References mixable_storage_.

                                     {
   mixable_storage_->get_model()->remove_row(id);
 }

void jubatus::core::anomaly::lof::get_all_row_ids ( std::vector< std::string > & ids ) const

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 124 of file lof.cpp.

References mixable_storage_.

                                                    {
   mixable_storage_->get_model()->get_all_row_ids(ids);
 }

std::vector< framework::mixable * > jubatus::core::anomaly::lof::get_mixables ( ) const

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 132 of file lof.cpp.

References mixable_storage_, and nn_engine_.

                                                      {
   std::vector<framework::mixable*> mixables;
   mixables.push_back(mixable_storage_.get());
   mixables.push_back(nn_engine_->get_mixable());
   return mixables;
 }

bool jubatus::core::anomaly::lof::is_updatable ( ) const

inlinevirtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 55 of file lof.hpp.

                             {
     return true;
   }

void jubatus::core::anomaly::lof::pack ( framework::packer & packer ) const

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 139 of file lof.cpp.

References mixable_storage_, and nn_engine_.

                                             {
   packer.pack_array(2);
   mixable_storage_->get_model()->pack(packer);
   nn_engine_->pack(packer);
 }

void jubatus::core::anomaly::lof::set_row	(	const std::string &	id,
		const common::sfv_t &	sfv
	)

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 120 of file lof.cpp.

References JUBATUS_EXCEPTION.

                                                           {
   throw JUBATUS_EXCEPTION(common::unsupported_method(__func__));
 }

string jubatus::core::anomaly::lof::type ( ) const

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 128 of file lof.cpp.

                        {
   return "lof";
 }

void jubatus::core::anomaly::lof::unpack ( msgpack::object o )

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 145 of file lof.cpp.

References mixable_storage_, and nn_engine_.

                                 {
   if (o.type != msgpack::type::ARRAY || o.via.array.size != 2) {
     throw msgpack::type_error();
   }
 
   // clear before load
   mixable_storage_->get_model()->clear();
   nn_engine_->clear();
 
   mixable_storage_->get_model()->unpack(o.via.array.ptr[0]);
   nn_engine_->unpack(o.via.array.ptr[1]);
 }

void jubatus::core::anomaly::lof::update_row	(	const std::string &	id,
		const sfv_diff_t &	diff
	)

virtual

Implements jubatus::core::anomaly::anomaly_base.

Definition at line 116 of file lof.cpp.

References mixable_storage_.

                                                              {
   mixable_storage_->get_model()->update_row(id, diff);
 }

Member Data Documentation

jubatus::util::lang::shared_ptr<mixable_lof_storage> jubatus::core::anomaly::lof::mixable_storage_

private

Definition at line 60 of file lof.hpp.

Referenced by calc_anomaly_score(), clear(), clear_row(), get_all_row_ids(), get_mixables(), lof(), pack(), unpack(), and update_row().

jubatus::util::lang::shared_ptr<recommender::recommender_base> jubatus::core::anomaly::lof::nn_engine_

private

Definition at line 61 of file lof.hpp.

Referenced by get_mixables(), pack(), and unpack().

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

jubatus/core/anomaly/lof.hpp
jubatus/core/anomaly/lof.cpp

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation