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;
241 class DAAL_EXPORT DistributedBase :
public daal::algorithms::Analysis<distributed>
244 typedef algorithms::kmeans::init::Parameter ParameterType;
246 virtual ~DistributedBase() { }
249 DistributedBase() { }
251 explicit DistributedBase(ParameterType *parameter)
274 template<ComputeStep step,
typename algorithmFPType = DAAL_ALGORITHM_FP_TYPE, Method method = defaultDense>
275 class DAAL_EXPORT Distributed;
294 template<
typename algorithmFPType, Method method>
295 class DAAL_EXPORT Distributed<step1Local, algorithmFPType, method> :
public DistributedBase
298 typedef algorithms::kmeans::init::Input InputType;
299 typedef algorithms::kmeans::init::Result ResultType;
300 typedef algorithms::kmeans::init::PartialResult PartialResultType;
308 Distributed(
size_t nClusters,
size_t nRowsTotal,
size_t offset = 0);
314 Distributed(
const Distributed<step1Local, algorithmFPType, method> &other);
320 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
326 ResultPtr getResult()
335 services::Status setResult(
const ResultPtr& result)
337 DAAL_CHECK(result, services::ErrorNullResult)
339 _res = _result.get();
340 return services::Status();
347 PartialResultPtr getPartialResult()
349 return _partialResult;
356 services::Status setPartialResult(
const PartialResultPtr& partialRes)
358 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
359 _partialResult = partialRes;
360 _pres = _partialResult.get();
361 return services::Status();
367 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
369 return services::Status();
377 services::SharedPtr<Distributed<step1Local, algorithmFPType, method> > clone()
const
379 return services::SharedPtr<Distributed<step1Local, algorithmFPType, method> >(cloneImpl());
383 virtual Distributed<step1Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
385 return new Distributed<step1Local, algorithmFPType, method>(*this);
388 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
390 _result.reset(
new ResultType());
391 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int) method);
392 _res = _result.get();
396 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
398 _partialResult.reset(
new PartialResultType());
399 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
400 _pres = _partialResult.get();
404 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
406 return services::Status();
411 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step1Local, algorithmFPType, method)(&_env);
417 ParameterType ¶meter;
420 PartialResultPtr _partialResult;
441 template<
typename algorithmFPType, Method method>
442 class DAAL_EXPORT Distributed<step2Master, algorithmFPType, method> :
public DistributedBase
445 typedef algorithms::kmeans::init::DistributedStep2MasterInput InputType;
446 typedef algorithms::kmeans::init::Result ResultType;
447 typedef algorithms::kmeans::init::PartialResult PartialResultType;
454 Distributed(
size_t nClusters,
size_t offset = 0);
460 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
466 ResultPtr getResult()
474 services::Status setResult(
const ResultPtr& result)
476 DAAL_CHECK(result, services::ErrorNullResult)
478 _res = _result.get();
479 return services::Status();
486 PartialResultPtr getPartialResult()
488 return _partialResult;
495 services::Status setPartialResult(
const PartialResultPtr& partialRes)
497 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
498 _partialResult = partialRes;
499 _pres = _partialResult.get();
500 return services::Status();
506 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
511 s |= _partialResult->check(_par, method);
512 if (!s) {
return s; }
516 return services::Status(services::ErrorNullResult);
521 s |= _result->check(&input, _par, method);
525 return services::Status(services::ErrorNullResult);
535 services::SharedPtr<Distributed<step2Master, algorithmFPType, method> > clone()
const
537 return services::SharedPtr<Distributed<step2Master, algorithmFPType, method> >(cloneImpl());
541 virtual Distributed<step2Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
543 return new Distributed<step2Master, algorithmFPType, method>(*this);
546 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
548 _result.reset(
new ResultType());
549 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
550 _res = _result.get();
554 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
556 _partialResult.reset(
new PartialResultType());
557 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
559 _pres = _partialResult.get();
562 _result.reset(
new ResultType());
563 s |= _result->allocate<algorithmFPType>(&input, _par, (int)method);
564 _res = _result.get();
569 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
571 return services::Status();
576 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Master, algorithmFPType, method)(&_env);
582 ParameterType ¶meter;
585 PartialResultPtr _partialResult;
593 class DAAL_EXPORT DistributedStep2LocalPlusPlusBase :
public daal::algorithms::Analysis<distributed>
596 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusParameter ParameterType;
598 virtual ~DistributedStep2LocalPlusPlusBase() { }
601 DistributedStep2LocalPlusPlusBase() { }
603 explicit DistributedStep2LocalPlusPlusBase(ParameterType *parameter)
630 template<
typename algorithmFPType, Method method>
631 class DAAL_EXPORT Distributed<step2Local, algorithmFPType, method> :
public DistributedStep2LocalPlusPlusBase
634 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusInput InputType;
635 typedef algorithms::kmeans::init::DistributedStep2LocalPlusPlusPartialResult PartialResultType;
642 Distributed(
size_t nClusters,
bool bFirstIteration);
649 Distributed(
const Distributed<step2Local, algorithmFPType, method> &other);
655 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
661 DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
663 return _partialResult;
670 services::Status setPartialResult(
const DistributedStep2LocalPlusPlusPartialResultPtr& partialRes)
672 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
673 _partialResult = partialRes;
674 _pres = _partialResult.get();
675 return services::Status();
681 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
683 return services::Status();
691 services::SharedPtr<Distributed<step2Local, algorithmFPType, method> > clone()
const
693 return services::SharedPtr<Distributed<step2Local, algorithmFPType, method> >(cloneImpl());
697 virtual Distributed<step2Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
699 return new Distributed<step2Local, algorithmFPType, method>(*this);
702 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
704 return services::Status();
707 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
709 _partialResult.reset(
new DistributedStep2LocalPlusPlusPartialResult());
710 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
711 _pres = _partialResult.get();
715 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
717 _partialResult->initialize(&input, _par, (
int)method);
718 return services::Status();
723 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Local, algorithmFPType, method)(&_env);
729 ParameterType ¶meter;
732 DistributedStep2LocalPlusPlusPartialResultPtr _partialResult;
755 template<
typename algorithmFPType, Method method>
756 class DAAL_EXPORT Distributed<step3Master, algorithmFPType, method> :
public DistributedBase
759 typedef algorithms::kmeans::init::DistributedStep3MasterPlusPlusInput InputType;
760 typedef algorithms::kmeans::init::DistributedStep3MasterPlusPlusPartialResult PartialResultType;
766 Distributed(
size_t nClusters);
772 Distributed(
const Distributed<step3Master, algorithmFPType, method> &other);
778 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
784 DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
786 return _partialResult;
793 services::Status setPartialResult(
const DistributedStep3MasterPlusPlusPartialResultPtr& partialRes)
795 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
796 _partialResult = partialRes;
797 _pres = _partialResult.get();
798 return services::Status();
804 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
806 return services::Status();
814 services::SharedPtr<Distributed<step3Master, algorithmFPType, method> > clone()
const
816 return services::SharedPtr<Distributed<step3Master, algorithmFPType, method> >(cloneImpl());
820 virtual Distributed<step3Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
822 return new Distributed<step3Master, algorithmFPType, method>(*this);
825 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
827 return services::Status();
830 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
832 _partialResult.reset(
new PartialResultType());
833 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
834 _pres = _partialResult.get();
838 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
840 _partialResult->initialize(&input, _par, (
int)method);
841 return services::Status();
846 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step3Master, algorithmFPType, method)(&_env);
852 ParameterType ¶meter;
855 DistributedStep3MasterPlusPlusPartialResultPtr _partialResult;
878 template<
typename algorithmFPType, Method method>
879 class DAAL_EXPORT Distributed<step4Local, algorithmFPType, method> :
public DistributedBase
882 typedef algorithms::kmeans::init::DistributedStep4LocalPlusPlusInput InputType;
883 typedef algorithms::kmeans::init::DistributedStep4LocalPlusPlusPartialResult PartialResultType;
889 Distributed(
size_t nClusters);
895 Distributed(
const Distributed<step4Local, algorithmFPType, method> &other);
901 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
907 DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
909 return _partialResult;
916 services::Status setPartialResult(
const DistributedStep4LocalPlusPlusPartialResultPtr& partialRes)
918 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
919 _partialResult = partialRes;
920 _pres = _partialResult.get();
921 return services::Status();
927 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
929 return services::Status();
937 services::SharedPtr<Distributed<step4Local, algorithmFPType, method> > clone()
const
939 return services::SharedPtr<Distributed<step4Local, algorithmFPType, method> >(cloneImpl());
943 virtual Distributed<step4Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
945 return new Distributed<step4Local, algorithmFPType, method>(*this);
948 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
950 return services::Status();
953 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
955 _partialResult.reset(
new PartialResultType());
956 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
957 _pres = _partialResult.get();
961 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
963 return services::Status();
968 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step4Local, algorithmFPType, method)(&_env);
974 ParameterType ¶meter;
977 DistributedStep4LocalPlusPlusPartialResultPtr _partialResult;
1000 template<
typename algorithmFPType, Method method>
1001 class DAAL_EXPORT Distributed<step5Master, algorithmFPType, method> :
public DistributedBase
1004 typedef algorithms::kmeans::init::DistributedStep5MasterPlusPlusInput InputType;
1005 typedef algorithms::kmeans::init::Result ResultType;
1006 typedef algorithms::kmeans::init::DistributedStep5MasterPlusPlusPartialResult PartialResultType;
1012 Distributed(
size_t nClusters);
1019 Distributed(
const Distributed<step5Master, algorithmFPType, method> &other);
1025 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
1031 ResultPtr getResult()
1040 services::Status setResult(
const ResultPtr& result)
1042 DAAL_CHECK(result, services::ErrorNullResult)
1044 _res = _result.get();
1045 return services::Status();
1052 DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
1054 return _partialResult;
1061 services::Status setPartialResult(
const DistributedStep5MasterPlusPlusPartialResultPtr& partialRes)
1063 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1064 _partialResult = partialRes;
1065 _pres = _partialResult.get();
1066 return services::Status();
1072 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
1074 return services::Status();
1082 services::SharedPtr<Distributed<step5Master, algorithmFPType, method> > clone()
const
1084 return services::SharedPtr<Distributed<step5Master, algorithmFPType, method> >(cloneImpl());
1088 virtual Distributed<step5Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1090 return new Distributed<step5Master, algorithmFPType, method>(*this);
1093 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1095 _result.reset(
new ResultType());
1096 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
1097 _res = _result.get();
1101 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1103 _partialResult.reset(
new PartialResultType());
1104 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
1105 _pres = _partialResult.get();
1109 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1111 return services::Status();
1116 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step5Master, algorithmFPType, method)(&_env);
1122 ParameterType ¶meter;
1125 DistributedStep5MasterPlusPlusPartialResultPtr _partialResult;
1129 using interface2::DistributedContainer;
1130 using interface2::DistributedBase;
1131 using interface2::DistributedStep2LocalPlusPlusBase;
1132 using interface2::Distributed;
daal::step2Local
Definition: daal_defines.h:126
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step5Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:1082
daal
Definition: algorithm_base_common.h:31
daal::step5Master
Definition: daal_defines.h:128
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::interface2::Distributed< step4Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep4LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:916
daal::algorithms::kmeans::init::interface2::Distributed< step4Local, algorithmFPType, method >::getPartialResult
DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:907
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep3MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:793
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::checkFinalizeComputeParams
services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:367
daal::algorithms::kmeans::init::interface2::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:442
daal::services::ErrorNullPartialResult
Definition: error_indexes.h:105
daal::algorithms::kmeans::init::interface2::DistributedBase
Base class representing an K-Means algorithm initialization in the distributed processing mode...
Definition: kmeans_init_distributed.h:241
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::parameter
ParameterType & parameter
Definition: kmeans_init_distributed.h:417
daal::step3Master
Definition: daal_defines.h:127
daal::algorithms::kmeans::init::interface2::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:631
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >::getPartialResult
DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:784
daal::algorithms::kmeans::init::interface2::Distributed
class DAAL_EXPORT Distributed
Computes initial clusters for the K-Means algorithm in the distributed processing mode...
Definition: kmeans_init_distributed.h:275
daal::distributed
Definition: daal_defines.h:111
daal::algorithms::kmeans::init::interface2::Distributed< step2Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:535
daal::algorithms::kmeans::init::interface2::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:879
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const PartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:356
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::input
InputType input
Definition: kmeans_init_distributed.h:416
daal::algorithms::kmeans::init::interface2::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:756
daal::algorithms::kmeans::init::interface2::Distributed< step3Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step3Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:814
daal::algorithms::kmeans::init::interface2::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:1001
daal::step4Local
Definition: daal_defines.h:124
daal::algorithms::kmeans::init::interface2::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::interface2::DistributedStep2LocalPlusPlusBase::~DistributedStep2LocalPlusPlusBase
virtual ~DistributedStep2LocalPlusPlusBase()
Definition: kmeans_init_distributed.h:598
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >::getPartialResult
DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:1052
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::getResult
ResultPtr getResult()
Definition: kmeans_init_distributed.h:326
daal::step1Local
Definition: daal_defines.h:121
daal::algorithms::kmeans::init::interface2::DistributedBase::~DistributedBase
virtual ~DistributedBase()
Definition: kmeans_init_distributed.h:246
daal::step2Master
Definition: daal_defines.h:122
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:691
daal::algorithms::implicit_als::training::offset
Definition: implicit_als_training_types.h:148
daal::algorithms::kmeans::init::interface2::DistributedStep2LocalPlusPlusBase
Base class representing an K-Means algorithm initialization in the distributed processing mode...
Definition: kmeans_init_distributed.h:593
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >::getPartialResult
DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:661
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::getPartialResult
PartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:347
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::setResult
services::Status setResult(const ResultPtr &result)
Definition: kmeans_init_distributed.h:335
daal::algorithms::kmeans::init::interface2::Distributed< step5Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep5MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:1061
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:320
daal::algorithms::kmeans::init::interface2::Distributed< step1Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step1Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:377
daal::algorithms::kmeans::init::interface2::Distributed< step2Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep2LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:670
daal::services::ErrorNullResult
Definition: error_indexes.h:96
daal::algorithms::kmeans::init::interface2::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:295
daal::algorithms::kmeans::init::interface2::Distributed< step4Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step4Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:937