23 #ifndef __KMEANS_INIT_DISTRIBITED_H__
24 #define __KMEANS_INIT_DISTRIBITED_H__
26 #include "algorithms/algorithm.h"
27 #include "data_management/data/numeric_table.h"
28 #include "services/daal_defines.h"
29 #include "algorithms/kmeans/kmeans_init_types.h"
56 template<ComputeStep step,
typename algorithmFPType, Method method, CpuType cpu>
57 class DAAL_EXPORT DistributedContainer;
63 template<
typename algorithmFPType, Method method, CpuType cpu>
64 class DAAL_EXPORT DistributedContainer<step1Local, algorithmFPType, method, cpu> :
public
65 daal::algorithms::AnalysisContainerIface<distributed>
73 DistributedContainer(daal::services::Environment::env *daalEnv);
75 virtual ~DistributedContainer();
80 virtual services::Status compute() DAAL_C11_OVERRIDE;
85 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
92 template<
typename algorithmFPType, Method method, CpuType cpu>
93 class DAAL_EXPORT DistributedContainer<step2Master, algorithmFPType, method, cpu> :
public
94 daal::algorithms::AnalysisContainerIface<distributed>
102 DistributedContainer(daal::services::Environment::env *daalEnv);
104 virtual ~DistributedContainer();
109 virtual services::Status compute() DAAL_C11_OVERRIDE;
114 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
122 template<
typename algorithmFPType, Method method, CpuType cpu>
123 class DAAL_EXPORT DistributedContainer<step2Local, algorithmFPType, method, cpu> :
public
124 daal::algorithms::AnalysisContainerIface<distributed>
132 DistributedContainer(daal::services::Environment::env *daalEnv);
134 virtual ~DistributedContainer();
139 virtual services::Status compute() DAAL_C11_OVERRIDE;
144 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
152 template<
typename algorithmFPType, Method method, CpuType cpu>
153 class DAAL_EXPORT DistributedContainer<step3Master, algorithmFPType, method, cpu> :
public
154 daal::algorithms::AnalysisContainerIface<distributed>
162 DistributedContainer(daal::services::Environment::env *daalEnv);
164 virtual ~DistributedContainer();
169 virtual services::Status compute() DAAL_C11_OVERRIDE;
174 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
182 template<
typename algorithmFPType, Method method, CpuType cpu>
183 class DAAL_EXPORT DistributedContainer<step4Local, algorithmFPType, method, cpu> :
public
184 daal::algorithms::AnalysisContainerIface<distributed>
192 DistributedContainer(daal::services::Environment::env *daalEnv);
194 virtual ~DistributedContainer();
199 virtual services::Status compute() DAAL_C11_OVERRIDE;
204 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
212 template<
typename algorithmFPType, Method method, CpuType cpu>
213 class DAAL_EXPORT DistributedContainer<step5Master, algorithmFPType, method, cpu> :
public
214 daal::algorithms::AnalysisContainerIface<distributed>
222 DistributedContainer(daal::services::Environment::env *daalEnv);
224 virtual ~DistributedContainer();
229 virtual services::Status compute() DAAL_C11_OVERRIDE;
234 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
254 template<ComputeStep step,
typename algorithmFPType = DAAL_ALGORITHM_FP_TYPE, Method method = defaultDense>
255 class DAAL_EXPORT Distributed;
274 template<
typename algorithmFPType, Method method>
275 class DAAL_EXPORT Distributed<step1Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
278 typedef algorithms::kmeans::init::Input InputType;
279 typedef algorithms::kmeans::init::Parameter ParameterType;
280 typedef algorithms::kmeans::init::Result ResultType;
281 typedef algorithms::kmeans::init::PartialResult PartialResultType;
289 Distributed(
size_t nClusters,
size_t nRowsTotal,
size_t offset = 0) : parameter(nClusters, offset)
292 parameter.nRowsTotal = nRowsTotal;
300 Distributed(
const Distributed<step1Local, algorithmFPType, method> &other) : parameter(other.parameter)
303 input.set(data, other.input.get(data));
310 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
316 ResultPtr getResult()
325 services::Status setResult(
const ResultPtr& result)
327 DAAL_CHECK(result, services::ErrorNullResult)
329 _res = _result.get();
330 return services::Status();
337 PartialResultPtr getPartialResult()
339 return _partialResult;
346 services::Status setPartialResult(
const PartialResultPtr& partialRes)
348 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
349 _partialResult = partialRes;
350 _pres = _partialResult.get();
351 return services::Status();
357 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
359 return services::Status();
367 services::SharedPtr<Distributed<step1Local, algorithmFPType, method> > clone()
const
369 return services::SharedPtr<Distributed<step1Local, algorithmFPType, method> >(cloneImpl());
373 virtual Distributed<step1Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
375 return new Distributed<step1Local, algorithmFPType, method>(*this);
378 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
380 _result.reset(
new ResultType());
381 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int) method);
382 _res = _result.get();
386 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
388 _partialResult.reset(
new PartialResultType());
389 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
390 _pres = _partialResult.get();
394 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
396 return services::Status();
401 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step1Local, algorithmFPType, method)(&_env);
408 ParameterType parameter;
411 PartialResultPtr _partialResult;
432 template<
typename algorithmFPType, Method method>
433 class DAAL_EXPORT Distributed<step2Master, algorithmFPType, method>:
public daal::algorithms::Analysis<distributed>
436 typedef algorithms::kmeans::init::DistributedStep2MasterInput InputType;
437 typedef algorithms::kmeans::init::Parameter ParameterType;
438 typedef algorithms::kmeans::init::Result ResultType;
439 typedef algorithms::kmeans::init::PartialResult PartialResultType;
446 Distributed(
size_t nClusters,
size_t offset = 0) : parameter(nClusters, offset)
448 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Master, algorithmFPType, method)(&_env);
457 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
463 ResultPtr getResult()
471 services::Status setResult(
const ResultPtr& result)
473 DAAL_CHECK(result, services::ErrorNullResult)
475 _res = _result.get();
476 return services::Status();
483 PartialResultPtr getPartialResult()
485 return _partialResult;
492 services::Status setPartialResult(
const PartialResultPtr& partialRes)
494 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
495 _partialResult = partialRes;
496 _pres = _partialResult.get();
497 return services::Status();
503 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
508 s |= _partialResult->check(_par, method);
509 if (!s) {
return s; }
513 return services::Status(services::ErrorNullResult);
518 s |= _result->check(&input, _par, method);
522 return services::Status(services::ErrorNullResult);
532 services::SharedPtr<Distributed<step2Master, algorithmFPType, method> > clone()
const
534 return services::SharedPtr<Distributed<step2Master, algorithmFPType, method> >(cloneImpl());
538 virtual Distributed<step2Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
540 return new Distributed<step2Master, algorithmFPType, method>(*this);
543 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
545 _result.reset(
new ResultType());
546 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
547 _res = _result.get();
551 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
553 _partialResult.reset(
new PartialResultType());
554 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
556 _pres = _partialResult.get();
559 _result.reset(
new ResultType());
560 s |= _result->allocate<algorithmFPType>(&input, _par, (int)method);
561 _res = _result.get();
566 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
568 return services::Status();
573 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Master, algorithmFPType, method)(&_env);
580 ParameterType parameter;
583 PartialResultPtr _partialResult;
608 template<
typename algorithmFPType, Method method>
609 class DAAL_EXPORT Distributed<step2Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
612 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusInput InputType;
613 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusParameter ParameterType;
614 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusPartialResult PartialResultType;
621 Distributed(
size_t nClusters,
bool bFirstIteration) : parameter(nClusters, bFirstIteration)
631 Distributed(
const Distributed<step2Local, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
640 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
646 DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
648 return _partialResult;
655 services::Status setPartialResult(
const DistributedStep2LocalPlusPlusPartialResultPtr& partialRes)
657 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
658 _partialResult = partialRes;
659 _pres = _partialResult.get();
660 return services::Status();
666 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
668 return services::Status();
676 services::SharedPtr<Distributed<step2Local, algorithmFPType, method> > clone()
const
678 return services::SharedPtr<Distributed<step2Local, algorithmFPType, method> >(cloneImpl());
682 virtual Distributed<step2Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
684 return new Distributed<step2Local, algorithmFPType, method>(*this);
687 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
689 return services::Status();
692 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
694 _partialResult.reset(
new DistributedStep2LocalPlusPlusPartialResult());
695 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
696 _pres = _partialResult.get();
700 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
702 _partialResult->initialize(&input, _par, (
int)method);
703 return services::Status();
708 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Local, algorithmFPType, method)(&_env);
715 ParameterType parameter;
718 DistributedStep2LocalPlusPlusPartialResultPtr _partialResult;
741 template<
typename algorithmFPType, Method method>
742 class DAAL_EXPORT Distributed<step3Master, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
745 typedef algorithms::kmeans::init::DistributedStep3MasterPlusPlusInput InputType;
746 typedef algorithms::kmeans::init::Parameter ParameterType;
747 typedef algorithms::kmeans::init::DistributedStep3MasterPlusPlusPartialResult PartialResultType;
753 Distributed(
size_t nClusters) : parameter(nClusters)
763 Distributed(
const Distributed<step3Master, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
772 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
778 DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
780 return _partialResult;
787 services::Status setPartialResult(
const DistributedStep3MasterPlusPlusPartialResultPtr& partialRes)
789 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
790 _partialResult = partialRes;
791 _pres = _partialResult.get();
792 return services::Status();
798 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
800 return services::Status();
808 services::SharedPtr<Distributed<step3Master, algorithmFPType, method> > clone()
const
810 return services::SharedPtr<Distributed<step3Master, algorithmFPType, method> >(cloneImpl());
814 virtual Distributed<step3Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
816 return new Distributed<step3Master, algorithmFPType, method>(*this);
819 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
821 return services::Status();
824 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
826 _partialResult.reset(
new PartialResultType());
827 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
828 _pres = _partialResult.get();
832 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
834 _partialResult->initialize(&input, _par, (
int)method);
835 return services::Status();
840 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step3Master, algorithmFPType, method)(&_env);
847 ParameterType parameter;
850 DistributedStep3MasterPlusPlusPartialResultPtr _partialResult;
873 template<
typename algorithmFPType, Method method>
874 class DAAL_EXPORT Distributed<step4Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
877 typedef algorithms::kmeans::init::DistributedStep4LocalPlusPlusInput InputType;
878 typedef algorithms::kmeans::init::Parameter ParameterType;
879 typedef algorithms::kmeans::init::DistributedStep4LocalPlusPlusPartialResult PartialResultType;
885 Distributed(
size_t nClusters) : parameter(nClusters)
895 Distributed(
const Distributed<step4Local, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
904 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
910 DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
912 return _partialResult;
919 services::Status setPartialResult(
const DistributedStep4LocalPlusPlusPartialResultPtr& partialRes)
921 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
922 _partialResult = partialRes;
923 _pres = _partialResult.get();
924 return services::Status();
930 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
932 return services::Status();
940 services::SharedPtr<Distributed<step4Local, algorithmFPType, method> > clone()
const
942 return services::SharedPtr<Distributed<step4Local, algorithmFPType, method> >(cloneImpl());
946 virtual Distributed<step4Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
948 return new Distributed<step4Local, algorithmFPType, method>(*this);
951 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
953 return services::Status();
956 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
958 _partialResult.reset(
new PartialResultType());
959 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
960 _pres = _partialResult.get();
964 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
966 return services::Status();
971 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step4Local, algorithmFPType, method)(&_env);
978 ParameterType parameter;
981 DistributedStep4LocalPlusPlusPartialResultPtr _partialResult;
1004 template<
typename algorithmFPType, Method method>
1005 class DAAL_EXPORT Distributed<step5Master, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1008 typedef algorithms::kmeans::init::DistributedStep5MasterPlusPlusInput InputType;
1009 typedef algorithms::kmeans::init::Parameter ParameterType;
1010 typedef algorithms::kmeans::init::Result ResultType;
1011 typedef algorithms::kmeans::init::DistributedStep5MasterPlusPlusPartialResult PartialResultType;
1017 Distributed(
size_t nClusters) : parameter(nClusters)
1027 Distributed(
const Distributed<step5Master, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
1036 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
1042 ResultPtr getResult()
1051 services::Status setResult(
const ResultPtr& result)
1053 DAAL_CHECK(result, services::ErrorNullResult)
1055 _res = _result.get();
1056 return services::Status();
1063 DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
1065 return _partialResult;
1072 services::Status setPartialResult(
const DistributedStep5MasterPlusPlusPartialResultPtr& partialRes)
1074 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1075 _partialResult = partialRes;
1076 _pres = _partialResult.get();
1077 return services::Status();
1083 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
1085 return services::Status();
1093 services::SharedPtr<Distributed<step5Master, algorithmFPType, method> > clone()
const
1095 return services::SharedPtr<Distributed<step5Master, algorithmFPType, method> >(cloneImpl());
1099 virtual Distributed<step5Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1101 return new Distributed<step5Master, algorithmFPType, method>(*this);
1104 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1106 _result.reset(
new ResultType());
1107 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
1108 _res = _result.get();
1112 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1114 _partialResult.reset(
new PartialResultType());
1115 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
1116 _pres = _partialResult.get();
1120 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1122 return services::Status();
1127 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step5Master, algorithmFPType, method)(&_env);
1134 ParameterType parameter;
1137 DistributedStep5MasterPlusPlusPartialResultPtr _partialResult;
1141 using interface1::DistributedContainer;
1142 using interface1::Distributed;
daal::step2Local
Definition: daal_defines.h:122
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::Distributed
Distributed(const Distributed< step3Master, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:763
daal::algorithms::kmeans::init::data
Definition: kmeans_init_types.h:83
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::Distributed
Distributed(const Distributed< step2Local, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:631
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::Distributed
Distributed(size_t nClusters)
Definition: kmeans_init_distributed.h:753
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step5Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:1093
daal
Definition: algorithm_base_common.h:31
daal::step5Master
Definition: daal_defines.h:124
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >
Computes initial clusters for the K-Means algorithm in the 4th step of the distributed processing mod...
Definition: kmeans_init_distributed.h:874
daal::algorithms::AnalysisContainerIface
Abstract interface class that provides virtual methods to access and run implementations of the analy...
Definition: analysis.h:53
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep4LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:919
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::Distributed
Distributed(const Distributed< step5Master, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:1027
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::getPartialResult
DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:910
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep3MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:787
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::checkFinalizeComputeParams
services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:357
daal::algorithms::kmeans::init::interface1::Distributed< step2Master, algorithmFPType, method >
Computes initial clusters for the K-Means algorithm in the 2nd step of the distributed processing mod...
Definition: kmeans_init_distributed.h:433
daal::algorithms::kmeans::init::interface1::Distributed< step2Master, algorithmFPType, method >::Distributed
Distributed(size_t nClusters, size_t offset=0)
Definition: kmeans_init_distributed.h:446
daal::services::ErrorNullPartialResult
Definition: error_indexes.h:105
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::parameter
ParameterType parameter
Definition: kmeans_init_distributed.h:408
daal::step3Master
Definition: daal_defines.h:123
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::getPartialResult
DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:778
daal::algorithms::kmeans::init::interface1::Distributed
class DAAL_EXPORT Distributed
Computes initial clusters for the K-Means algorithm in the distributed processing mode...
Definition: kmeans_init_distributed.h:255
daal::distributed
Definition: daal_defines.h:107
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::Distributed
Distributed(const Distributed< step4Local, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:895
daal::algorithms::kmeans::init::interface1::Distributed< step2Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:532
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >
Computes initial clusters for the K-Means algorithm in the 2nd step of the distributed processing mod...
Definition: kmeans_init_distributed.h:609
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const PartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:346
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::input
InputType input
Definition: kmeans_init_distributed.h:407
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >
Computes initial clusters for the K-Means algorithm in the 3rd step of the distributed processing mod...
Definition: kmeans_init_distributed.h:742
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::Distributed
Distributed(const Distributed< step1Local, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:300
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step3Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:808
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >
Computes initial clusters for the K-Means algorithm in the 5th step of the distributed processing mod...
Definition: kmeans_init_distributed.h:1005
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >
Computes initial clusters for the K-Means algorithm in the first step of the distributed processing m...
Definition: kmeans_init_distributed.h:275
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::Distributed
Distributed(size_t nClusters, size_t nRowsTotal, size_t offset=0)
Definition: kmeans_init_distributed.h:289
daal::step4Local
Definition: daal_defines.h:120
daal::algorithms::kmeans::init::interface1::DistributedContainer
class DAAL_EXPORT DistributedContainer
Provides methods to run implementations of initialization of the K-Means algorithm. This class is associated with the daal::algorithms::kmeans::init::Distributed class and supports the method of computing initial clusters for the K-Means algorithm in the distributed processing mode.
Definition: kmeans_init_distributed.h:57
daal::algorithms::Analysis
Provides methods for execution of operations over data, such as computation of Summary Statistics est...
Definition: analysis.h:68
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::getPartialResult
DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:1063
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::getResult
ResultPtr getResult()
Definition: kmeans_init_distributed.h:316
daal::step1Local
Definition: daal_defines.h:117
daal::step2Master
Definition: daal_defines.h:118
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:676
daal::algorithms::implicit_als::training::offset
Definition: implicit_als_training_types.h:148
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::getPartialResult
DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:646
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::getPartialResult
PartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:337
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::setResult
services::Status setResult(const ResultPtr &result)
Definition: kmeans_init_distributed.h:325
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep5MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:1072
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:310
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step1Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:367
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep2LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:655
daal::services::ErrorNullResult
Definition: error_indexes.h:96
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::Distributed
Distributed(size_t nClusters, bool bFirstIteration)
Definition: kmeans_init_distributed.h:621
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step4Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:940