jubatus::core::clustering::storage_factory Class Reference

#include <storage_factory.hpp>

Collaboration diagram for jubatus::core::clustering::storage_factory:

Static Public Member Functions
static jubatus::util::lang::shared_ptr< storage >	create (const std::string &name, const clustering_config &config)

Detailed Description

Definition at line 29 of file storage_factory.hpp.

Member Function Documentation

jubatus::util::lang::shared_ptr< storage > jubatus::core::clustering::storage_factory::create ( const std::string &  name, const clustering_config &  config  )

static

Definition at line 30 of file storage_factory.cpp.

References jubatus::core::clustering::clustering_config::compressor_method, JUBATUS_EXCEPTION, and jubatus::core::clustering::compressive_storage::set_compressor().

Referenced by jubatus::core::clustering::clustering::init().

                                     {
  typedef jubatus::util::lang::shared_ptr<storage> ptr;
  ptr ret;
  if (config.compressor_method == "compressive_kmeans") {
    compressive_storage *s = new compressive_storage(name, config);
    s->set_compressor(jubatus::util::lang::shared_ptr<compressor::compressor>(
                          new compressor::kmeans_compressor(config)));
    ret.reset(s);
#ifdef JUBATUS_USE_EIGEN
  } else if (config.compressor_method == "compressive_gmm") {
    compressive_storage *s = new compressive_storage(name, config);
    s->set_compressor(jubatus::util::lang::shared_ptr<compressor::compressor>(
                          new compressor::gmm_compressor(config)));
    ret.reset(s);
#endif
  } else if (config.compressor_method == "simple") {
    simple_storage *s = new simple_storage(name, config);
    ret.reset(s);
  } else {
    throw JUBATUS_EXCEPTION(
        common::unsupported_method(config.compressor_method));
  }
  return ret;
}

Here is the call graph for this function:

Here is the caller graph for this function:

---

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

• jubatus/core/clustering/storage_factory.hpp
• jubatus/core/clustering/storage_factory.cpp