25 #ifndef __KMEANS_INIT_DISTRIBITED_H__
26 #define __KMEANS_INIT_DISTRIBITED_H__
28 #include "algorithms/algorithm.h"
29 #include "data_management/data/numeric_table.h"
30 #include "services/daal_defines.h"
31 #include "algorithms/kmeans/kmeans_init_types.h"
58 template<ComputeStep step,
typename algorithmFPType, Method method, CpuType cpu>
59 class DistributedContainer;
65 template<
typename algorithmFPType, Method method, CpuType cpu>
66 class DistributedContainer<step1Local, algorithmFPType, method, cpu> :
public
67 daal::algorithms::AnalysisContainerIface<distributed>
75 DistributedContainer(daal::services::Environment::env *daalEnv);
77 virtual ~DistributedContainer();
82 virtual services::Status compute() DAAL_C11_OVERRIDE;
87 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
94 template<
typename algorithmFPType, Method method, CpuType cpu>
95 class DistributedContainer<step2Master, algorithmFPType, method, cpu> :
public
96 daal::algorithms::AnalysisContainerIface<distributed>
104 DistributedContainer(daal::services::Environment::env *daalEnv);
106 virtual ~DistributedContainer();
111 virtual services::Status compute() DAAL_C11_OVERRIDE;
116 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
124 template<
typename algorithmFPType, Method method, CpuType cpu>
125 class DistributedContainer<step2Local, algorithmFPType, method, cpu> :
public
126 daal::algorithms::AnalysisContainerIface<distributed>
134 DistributedContainer(daal::services::Environment::env *daalEnv);
136 virtual ~DistributedContainer();
141 virtual services::Status compute() DAAL_C11_OVERRIDE;
146 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
154 template<
typename algorithmFPType, Method method, CpuType cpu>
155 class DistributedContainer<step3Master, algorithmFPType, method, cpu> :
public
156 daal::algorithms::AnalysisContainerIface<distributed>
164 DistributedContainer(daal::services::Environment::env *daalEnv);
166 virtual ~DistributedContainer();
171 virtual services::Status compute() DAAL_C11_OVERRIDE;
176 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
184 template<
typename algorithmFPType, Method method, CpuType cpu>
185 class DistributedContainer<step4Local, algorithmFPType, method, cpu> :
public
186 daal::algorithms::AnalysisContainerIface<distributed>
194 DistributedContainer(daal::services::Environment::env *daalEnv);
196 virtual ~DistributedContainer();
201 virtual services::Status compute() DAAL_C11_OVERRIDE;
206 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
214 template<
typename algorithmFPType, Method method, CpuType cpu>
215 class DistributedContainer<step5Master, algorithmFPType, method, cpu> :
public
216 daal::algorithms::AnalysisContainerIface<distributed>
224 DistributedContainer(daal::services::Environment::env *daalEnv);
226 virtual ~DistributedContainer();
231 virtual services::Status compute() DAAL_C11_OVERRIDE;
236 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
243 class DAAL_EXPORT DistributedBase :
public daal::algorithms::Analysis<distributed>
246 typedef algorithms::kmeans::init::Parameter ParameterType;
248 virtual ~DistributedBase() { }
251 DistributedBase() { }
253 explicit DistributedBase(ParameterType *parameter)
276 template<ComputeStep step,
typename algorithmFPType = DAAL_ALGORITHM_FP_TYPE, Method method = defaultDense>
277 class DAAL_EXPORT Distributed;
296 template<
typename algorithmFPType, Method method>
297 class DAAL_EXPORT Distributed<step1Local, algorithmFPType, method> :
public DistributedBase
300 typedef algorithms::kmeans::init::Input InputType;
301 typedef algorithms::kmeans::init::Result ResultType;
302 typedef algorithms::kmeans::init::PartialResult PartialResultType;
310 Distributed(
size_t nClusters,
size_t nRowsTotal,
size_t offset = 0);
316 Distributed(
const Distributed<step1Local, algorithmFPType, method> &other);
322 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
328 ResultPtr getResult()
337 services::Status setResult(
const ResultPtr& result)
339 DAAL_CHECK(result, services::ErrorNullResult)
341 _res = _result.get();
342 return services::Status();
349 PartialResultPtr getPartialResult()
351 return _partialResult;
358 services::Status setPartialResult(
const PartialResultPtr& partialRes)
360 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
361 _partialResult = partialRes;
362 _pres = _partialResult.get();
363 return services::Status();
369 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
371 return services::Status();
379 services::SharedPtr<Distributed<step1Local, algorithmFPType, method> > clone()
const
381 return services::SharedPtr<Distributed<step1Local, algorithmFPType, method> >(cloneImpl());
385 virtual Distributed<step1Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
387 return new Distributed<step1Local, algorithmFPType, method>(*this);
390 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
392 _result.reset(
new ResultType());
393 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int) method);
394 _res = _result.get();
398 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
400 _partialResult.reset(
new PartialResultType());
401 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
402 _pres = _partialResult.get();
406 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
408 return services::Status();
413 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step1Local, algorithmFPType, method)(&_env);
419 ParameterType ¶meter;
422 PartialResultPtr _partialResult;
443 template<
typename algorithmFPType, Method method>
444 class DAAL_EXPORT Distributed<step2Master, algorithmFPType, method> :
public DistributedBase
447 typedef algorithms::kmeans::init::DistributedStep2MasterInput InputType;
448 typedef algorithms::kmeans::init::Result ResultType;
449 typedef algorithms::kmeans::init::PartialResult PartialResultType;
456 Distributed(
size_t nClusters,
size_t offset = 0);
462 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
468 ResultPtr getResult()
476 services::Status setResult(
const ResultPtr& result)
478 DAAL_CHECK(result, services::ErrorNullResult)
480 _res = _result.get();
481 return services::Status();
488 PartialResultPtr getPartialResult()
490 return _partialResult;
497 services::Status setPartialResult(
const PartialResultPtr& partialRes)
499 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
500 _partialResult = partialRes;
501 _pres = _partialResult.get();
502 return services::Status();
508 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
513 s |= _partialResult->check(_par, method);
514 if (!s) {
return s; }
518 return services::Status(services::ErrorNullResult);
523 s |= _result->check(&input, _par, method);
527 return services::Status(services::ErrorNullResult);
537 services::SharedPtr<Distributed<step2Master, algorithmFPType, method> > clone()
const
539 return services::SharedPtr<Distributed<step2Master, algorithmFPType, method> >(cloneImpl());
543 virtual Distributed<step2Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
545 return new Distributed<step2Master, algorithmFPType, method>(*this);
548 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
550 _result.reset(
new ResultType());
551 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
552 _res = _result.get();
556 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
558 _partialResult.reset(
new PartialResultType());
559 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
561 _pres = _partialResult.get();
564 _result.reset(
new ResultType());
565 s |= _result->allocate<algorithmFPType>(&input, _par, (int)method);
566 _res = _result.get();
571 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
573 return services::Status();
578 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Master, algorithmFPType, method)(&_env);
584 ParameterType ¶meter;
587 PartialResultPtr _partialResult;
595 class DAAL_EXPORT DistributedStep2LocalPlusPlusBase :
public daal::algorithms::Analysis<distributed>
598 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusParameter ParameterType;
600 virtual ~DistributedStep2LocalPlusPlusBase() { }
603 DistributedStep2LocalPlusPlusBase() { }
605 explicit DistributedStep2LocalPlusPlusBase(ParameterType *parameter)
632 template<
typename algorithmFPType, Method method>
633 class DAAL_EXPORT Distributed<step2Local, algorithmFPType, method> :
public DistributedStep2LocalPlusPlusBase
636 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusInput InputType;
637 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusPartialResult PartialResultType;
644 Distributed(
size_t nClusters,
bool bFirstIteration);
651 Distributed(
const Distributed<step2Local, algorithmFPType, method> &other);
657 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
663 DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
665 return _partialResult;
672 services::Status setPartialResult(
const DistributedStep2LocalPlusPlusPartialResultPtr& partialRes)
674 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
675 _partialResult = partialRes;
676 _pres = _partialResult.get();
677 return services::Status();
683 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
685 return services::Status();
693 services::SharedPtr<Distributed<step2Local, algorithmFPType, method> > clone()
const
695 return services::SharedPtr<Distributed<step2Local, algorithmFPType, method> >(cloneImpl());
699 virtual Distributed<step2Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
701 return new Distributed<step2Local, algorithmFPType, method>(*this);
704 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
706 return services::Status();
709 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
711 _partialResult.reset(
new DistributedStep2LocalPlusPlusPartialResult());
712 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
713 _pres = _partialResult.get();
717 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
719 _partialResult->initialize(&input, _par, (
int)method);
720 return services::Status();
725 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Local, algorithmFPType, method)(&_env);
731 ParameterType ¶meter;
734 DistributedStep2LocalPlusPlusPartialResultPtr _partialResult;
757 template<
typename algorithmFPType, Method method>
758 class DAAL_EXPORT Distributed<step3Master, algorithmFPType, method> :
public DistributedBase
761 typedef algorithms::kmeans::init::DistributedStep3MasterPlusPlusInput InputType;
762 typedef algorithms::kmeans::init::DistributedStep3MasterPlusPlusPartialResult PartialResultType;
768 Distributed(
size_t nClusters);
774 Distributed(
const Distributed<step3Master, algorithmFPType, method> &other);
780 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
786 DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
788 return _partialResult;
795 services::Status setPartialResult(
const DistributedStep3MasterPlusPlusPartialResultPtr& partialRes)
797 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
798 _partialResult = partialRes;
799 _pres = _partialResult.get();
800 return services::Status();
806 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
808 return services::Status();
816 services::SharedPtr<Distributed<step3Master, algorithmFPType, method> > clone()
const
818 return services::SharedPtr<Distributed<step3Master, algorithmFPType, method> >(cloneImpl());
822 virtual Distributed<step3Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
824 return new Distributed<step3Master, algorithmFPType, method>(*this);
827 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
829 return services::Status();
832 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
834 _partialResult.reset(
new PartialResultType());
835 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
836 _pres = _partialResult.get();
840 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
842 _partialResult->initialize(&input, _par, (
int)method);
843 return services::Status();
848 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step3Master, algorithmFPType, method)(&_env);
854 ParameterType ¶meter;
857 DistributedStep3MasterPlusPlusPartialResultPtr _partialResult;
880 template<
typename algorithmFPType, Method method>
881 class DAAL_EXPORT Distributed<step4Local, algorithmFPType, method> :
public DistributedBase
884 typedef algorithms::kmeans::init::DistributedStep4LocalPlusPlusInput InputType;
885 typedef algorithms::kmeans::init::DistributedStep4LocalPlusPlusPartialResult PartialResultType;
891 Distributed(
size_t nClusters);
897 Distributed(
const Distributed<step4Local, algorithmFPType, method> &other);
903 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
909 DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
911 return _partialResult;
918 services::Status setPartialResult(
const DistributedStep4LocalPlusPlusPartialResultPtr& partialRes)
920 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
921 _partialResult = partialRes;
922 _pres = _partialResult.get();
923 return services::Status();
929 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
931 return services::Status();
939 services::SharedPtr<Distributed<step4Local, algorithmFPType, method> > clone()
const
941 return services::SharedPtr<Distributed<step4Local, algorithmFPType, method> >(cloneImpl());
945 virtual Distributed<step4Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
947 return new Distributed<step4Local, algorithmFPType, method>(*this);
950 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
952 return services::Status();
955 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
957 _partialResult.reset(
new PartialResultType());
958 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
959 _pres = _partialResult.get();
963 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
965 return services::Status();
970 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step4Local, algorithmFPType, method)(&_env);
976 ParameterType ¶meter;
979 DistributedStep4LocalPlusPlusPartialResultPtr _partialResult;
1002 template<
typename algorithmFPType, Method method>
1003 class DAAL_EXPORT Distributed<step5Master, algorithmFPType, method> :
public DistributedBase
1006 typedef algorithms::kmeans::init::DistributedStep5MasterPlusPlusInput InputType;
1007 typedef algorithms::kmeans::init::Result ResultType;
1008 typedef algorithms::kmeans::init::DistributedStep5MasterPlusPlusPartialResult PartialResultType;
1014 Distributed(
size_t nClusters);
1021 Distributed(
const Distributed<step5Master, algorithmFPType, method> &other);
1027 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
1033 ResultPtr getResult()
1042 services::Status setResult(
const ResultPtr& result)
1044 DAAL_CHECK(result, services::ErrorNullResult)
1046 _res = _result.get();
1047 return services::Status();
1054 DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
1056 return _partialResult;
1063 services::Status setPartialResult(
const DistributedStep5MasterPlusPlusPartialResultPtr& partialRes)
1065 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1066 _partialResult = partialRes;
1067 _pres = _partialResult.get();
1068 return services::Status();
1074 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
1076 return services::Status();
1084 services::SharedPtr<Distributed<step5Master, algorithmFPType, method> > clone()
const
1086 return services::SharedPtr<Distributed<step5Master, algorithmFPType, method> >(cloneImpl());
1090 virtual Distributed<step5Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1092 return new Distributed<step5Master, algorithmFPType, method>(*this);
1095 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1097 _result.reset(
new ResultType());
1098 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
1099 _res = _result.get();
1103 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1105 _partialResult.reset(
new PartialResultType());
1106 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
1107 _pres = _partialResult.get();
1111 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1113 return services::Status();
1118 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step5Master, algorithmFPType, method)(&_env);
1124 ParameterType ¶meter;
1127 DistributedStep5MasterPlusPlusPartialResultPtr _partialResult;
1131 using interface2::DistributedContainer;
1132 using interface2::DistributedBase;
1133 using interface2::DistributedStep2LocalPlusPlusBase;
1134 using interface2::Distributed;
daal::step1Local
Definition: daal_defines.h:123
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::input
InputType input
Definition: kmeans_init_distributed.h:418
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::parameter
ParameterType & parameter
Definition: kmeans_init_distributed.h:419
daal::algorithms::kmeans::init::interface2::DistributedBase::~DistributedBase
virtual ~DistributedBase()
Definition: kmeans_init_distributed.h:248
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:693
daal::algorithms::kmeans::init::interface2::Distributed< step4Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step4Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:939
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >::getPartialResult
DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:1054
daal::algorithms::kmeans::init::interface2::DistributedStep2LocalPlusPlusBase::~DistributedStep2LocalPlusPlusBase
virtual ~DistributedStep2LocalPlusPlusBase()
Definition: kmeans_init_distributed.h:600
daal::algorithms::kmeans::init::interface2::DistributedStep2LocalPlusPlusBase
Base class representing K-Means algorithm initialization in the distributed processing mode...
Definition: kmeans_init_distributed.h:595
daal::step2Master
Definition: daal_defines.h:124
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >::getPartialResult
DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:786
daal::algorithms::kmeans::init::interface2::Distributed< step4Local, algorithmFPType, method >::getPartialResult
DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:909
daal::step3Master
Definition: daal_defines.h:129
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::getResult
ResultPtr getResult()
Definition: kmeans_init_distributed.h:328
daal::services::ErrorNullResult
Definition: error_indexes.h:98
daal::algorithms::AnalysisContainerIface
Abstract interface class that provides virtual methods to access and run implementations of the analy...
Definition: analysis.h:55
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::getPartialResult
PartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:349
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step3Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:816
daal::algorithms::kmeans::init::interface2::Distributed
class DAAL_EXPORT Distributed
Computes initial clusters for K-Means algorithm in the distributed processing mode.
Definition: kmeans_init_distributed.h:277
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step1Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:379
daal::algorithms::kmeans::init::interface2::Distributed< step2Master, algorithmFPType, method >
Computes initial clusters for K-Means algorithm in the 2nd step of the distributed processing mode...
Definition: kmeans_init_distributed.h:444
daal::step4Local
Definition: daal_defines.h:126
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >
Computes initial clusters for K-Means algorithm in the first step of the distributed processing mode...
Definition: kmeans_init_distributed.h:297
daal::algorithms::kmeans::init::interface2::DistributedContainer
Provides methods to run implementations of initialization of K-Means algorithm. This class is associa...
Definition: kmeans_init_distributed.h:59
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:322
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step5Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:1084
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::setResult
services::Status setResult(const ResultPtr &result)
Definition: kmeans_init_distributed.h:337
daal::step5Master
Definition: daal_defines.h:130
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep3MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:795
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::checkFinalizeComputeParams
services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:369
daal::algorithms::kmeans::init::interface2::DistributedBase
Base class representing K-Means algorithm initialization in the distributed processing mode...
Definition: kmeans_init_distributed.h:243
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep5MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:1063
daal::algorithms::kmeans::init::interface2::Distributed< step2Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:537
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >::getPartialResult
DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:663
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >
Computes initial clusters for K-Means algorithm in the 5th step of the distributed processing mode...
Definition: kmeans_init_distributed.h:1003
daal::algorithms::kmeans::init::interface2::Distributed< step4Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep4LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:918
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const PartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:358
daal::algorithms::Analysis
Provides methods for execution of operations over data, such as computation of Summary Statistics est...
Definition: analysis.h:70
daal::services::ErrorNullPartialResult
Definition: error_indexes.h:107
daal::distributed
Definition: daal_defines.h:113
daal::algorithms::kmeans::init::interface2::Distributed< step4Local, algorithmFPType, method >
Computes initial clusters for K-Means algorithm in the 4th step of the distributed processing mode...
Definition: kmeans_init_distributed.h:881
daal::step2Local
Definition: daal_defines.h:128
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >
Computes initial clusters for K-Means algorithm in the 2nd step of the distributed processing mode...
Definition: kmeans_init_distributed.h:633
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep2LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:672
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >
Computes initial clusters for K-Means algorithm in the 3rd step of the distributed processing mode...
Definition: kmeans_init_distributed.h:758