49 #ifndef __KMEANS_INIT_DISTRIBITED_H__
50 #define __KMEANS_INIT_DISTRIBITED_H__
52 #include "algorithms/algorithm.h"
53 #include "data_management/data/numeric_table.h"
54 #include "services/daal_defines.h"
55 #include "algorithms/kmeans/kmeans_init_types.h"
82 template<ComputeStep step,
typename algorithmFPType, Method method, CpuType cpu>
83 class DAAL_EXPORT DistributedContainer;
89 template<
typename algorithmFPType, Method method, CpuType cpu>
90 class DAAL_EXPORT DistributedContainer<step1Local, algorithmFPType, method, cpu> :
public
91 daal::algorithms::AnalysisContainerIface<distributed>
99 DistributedContainer(daal::services::Environment::env *daalEnv);
101 virtual ~DistributedContainer();
106 virtual services::Status compute() DAAL_C11_OVERRIDE;
111 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
118 template<
typename algorithmFPType, Method method, CpuType cpu>
119 class DAAL_EXPORT DistributedContainer<step2Master, algorithmFPType, method, cpu> :
public
120 daal::algorithms::AnalysisContainerIface<distributed>
128 DistributedContainer(daal::services::Environment::env *daalEnv);
130 virtual ~DistributedContainer();
135 virtual services::Status compute() DAAL_C11_OVERRIDE;
140 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
148 template<
typename algorithmFPType, Method method, CpuType cpu>
149 class DAAL_EXPORT DistributedContainer<step2Local, algorithmFPType, method, cpu> :
public
150 daal::algorithms::AnalysisContainerIface<distributed>
158 DistributedContainer(daal::services::Environment::env *daalEnv);
160 virtual ~DistributedContainer();
165 virtual services::Status compute() DAAL_C11_OVERRIDE;
170 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
178 template<
typename algorithmFPType, Method method, CpuType cpu>
179 class DAAL_EXPORT DistributedContainer<step3Master, algorithmFPType, method, cpu> :
public
180 daal::algorithms::AnalysisContainerIface<distributed>
188 DistributedContainer(daal::services::Environment::env *daalEnv);
190 virtual ~DistributedContainer();
195 virtual services::Status compute() DAAL_C11_OVERRIDE;
200 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
208 template<
typename algorithmFPType, Method method, CpuType cpu>
209 class DAAL_EXPORT DistributedContainer<step4Local, algorithmFPType, method, cpu> :
public
210 daal::algorithms::AnalysisContainerIface<distributed>
218 DistributedContainer(daal::services::Environment::env *daalEnv);
220 virtual ~DistributedContainer();
225 virtual services::Status compute() DAAL_C11_OVERRIDE;
230 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
238 template<
typename algorithmFPType, Method method, CpuType cpu>
239 class DAAL_EXPORT DistributedContainer<step5Master, algorithmFPType, method, cpu> :
public
240 daal::algorithms::AnalysisContainerIface<distributed>
248 DistributedContainer(daal::services::Environment::env *daalEnv);
250 virtual ~DistributedContainer();
255 virtual services::Status compute() DAAL_C11_OVERRIDE;
260 virtual services::Status finalizeCompute() DAAL_C11_OVERRIDE;
280 template<ComputeStep step,
typename algorithmFPType = DAAL_ALGORITHM_FP_TYPE, Method method = defaultDense>
281 class DAAL_EXPORT Distributed;
300 template<
typename algorithmFPType, Method method>
301 class DAAL_EXPORT Distributed<step1Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
310 Distributed(
size_t nClusters,
size_t nRowsTotal,
size_t offset = 0) : parameter(nClusters, offset)
313 parameter.nRowsTotal = nRowsTotal;
321 Distributed(
const Distributed<step1Local, algorithmFPType, method> &other) : parameter(other.parameter)
324 input.set(data, other.input.get(data));
331 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
337 ResultPtr getResult()
346 services::Status setResult(
const ResultPtr& result)
348 DAAL_CHECK(result, services::ErrorNullResult)
350 _res = _result.get();
351 return services::Status();
358 PartialResultPtr getPartialResult()
360 return _partialResult;
367 services::Status setPartialResult(
const PartialResultPtr& partialRes)
369 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
370 _partialResult = partialRes;
371 _pres = _partialResult.get();
372 return services::Status();
378 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
380 return services::Status();
388 services::SharedPtr<Distributed<step1Local, algorithmFPType, method> > clone()
const
390 return services::SharedPtr<Distributed<step1Local, algorithmFPType, method> >(cloneImpl());
394 virtual Distributed<step1Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
396 return new Distributed<step1Local, algorithmFPType, method>(*this);
399 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
401 _result.reset(
new Result());
402 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int) method);
403 _res = _result.get();
407 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
409 _partialResult.reset(
new PartialResult());
410 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
411 _pres = _partialResult.get();
415 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
417 return services::Status();
422 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step1Local, algorithmFPType, method)(&_env);
432 PartialResultPtr _partialResult;
453 template<
typename algorithmFPType, Method method>
454 class DAAL_EXPORT Distributed<step2Master, algorithmFPType, method>:
public daal::algorithms::Analysis<distributed>
462 Distributed(
size_t nClusters,
size_t offset = 0) : parameter(nClusters, offset)
464 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Master, algorithmFPType, method)(&_env);
473 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
479 ResultPtr getResult()
487 services::Status setResult(
const ResultPtr& result)
489 DAAL_CHECK(result, services::ErrorNullResult)
491 _res = _result.get();
492 return services::Status();
499 PartialResultPtr getPartialResult()
501 return _partialResult;
508 services::Status setPartialResult(
const PartialResultPtr& partialRes)
510 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
511 _partialResult = partialRes;
512 _pres = _partialResult.get();
513 return services::Status();
519 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
524 s |= _partialResult->check(_par, method);
525 if (!s) {
return s; }
529 return services::Status(services::ErrorNullResult);
534 s |= _result->check(&input, _par, method);
538 return services::Status(services::ErrorNullResult);
548 services::SharedPtr<Distributed<step2Master, algorithmFPType, method> > clone()
const
550 return services::SharedPtr<Distributed<step2Master, algorithmFPType, method> >(cloneImpl());
554 virtual Distributed<step2Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
556 return new Distributed<step2Master, algorithmFPType, method>(*this);
559 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
561 _result.reset(
new Result());
562 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
563 _res = _result.get();
567 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
569 _partialResult.reset(
new PartialResult());
570 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
572 _pres = _partialResult.get();
575 _result.reset(
new Result());
576 s |= _result->allocate<algorithmFPType>(&input, _par, (int)method);
577 _res = _result.get();
582 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
584 return services::Status();
589 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Master, algorithmFPType, method)(&_env);
595 DistributedStep2MasterInput input;
599 PartialResultPtr _partialResult;
624 template<
typename algorithmFPType, Method method>
625 class DAAL_EXPORT Distributed<step2Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
633 Distributed(
size_t nClusters,
bool bFirstIteration) : parameter(nClusters, bFirstIteration)
643 Distributed(
const Distributed<step2Local, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
652 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
658 DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
660 return _partialResult;
667 services::Status setPartialResult(
const DistributedStep2LocalPlusPlusPartialResultPtr& partialRes)
669 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
670 _partialResult = partialRes;
671 _pres = _partialResult.get();
672 return services::Status();
678 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
680 return services::Status();
688 services::SharedPtr<Distributed<step2Local, algorithmFPType, method> > clone()
const
690 return services::SharedPtr<Distributed<step2Local, algorithmFPType, method> >(cloneImpl());
694 virtual Distributed<step2Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
696 return new Distributed<step2Local, algorithmFPType, method>(*this);
699 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
701 return services::Status();
704 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
706 _partialResult.reset(
new DistributedStep2LocalPlusPlusPartialResult());
707 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
708 _pres = _partialResult.get();
712 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
714 _partialResult->initialize(&input, _par, (
int)method);
715 return services::Status();
720 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Local, algorithmFPType, method)(&_env);
726 DistributedStep2LocalPlusPlusInput input;
727 DistributedStep2LocalPlusPlusParameter parameter;
730 DistributedStep2LocalPlusPlusPartialResultPtr _partialResult;
753 template<
typename algorithmFPType, Method method>
754 class DAAL_EXPORT Distributed<step3Master, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
761 Distributed(
size_t nClusters) : parameter(nClusters)
771 Distributed(
const Distributed<step3Master, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
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 DistributedStep3MasterPlusPlusPartialResult());
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 DistributedStep3MasterPlusPlusInput input;
858 DistributedStep3MasterPlusPlusPartialResultPtr _partialResult;
881 template<
typename algorithmFPType, Method method>
882 class DAAL_EXPORT Distributed<step4Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
889 Distributed(
size_t nClusters) : parameter(nClusters)
899 Distributed(
const Distributed<step4Local, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
908 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
914 DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
916 return _partialResult;
923 services::Status setPartialResult(
const DistributedStep4LocalPlusPlusPartialResultPtr& partialRes)
925 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
926 _partialResult = partialRes;
927 _pres = _partialResult.get();
928 return services::Status();
934 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
936 return services::Status();
944 services::SharedPtr<Distributed<step4Local, algorithmFPType, method> > clone()
const
946 return services::SharedPtr<Distributed<step4Local, algorithmFPType, method> >(cloneImpl());
950 virtual Distributed<step4Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
952 return new Distributed<step4Local, algorithmFPType, method>(*this);
955 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
957 return services::Status();
960 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
962 _partialResult.reset(
new DistributedStep4LocalPlusPlusPartialResult());
963 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
964 _pres = _partialResult.get();
968 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
970 return services::Status();
975 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step4Local, algorithmFPType, method)(&_env);
981 DistributedStep4LocalPlusPlusInput input;
985 DistributedStep4LocalPlusPlusPartialResultPtr _partialResult;
1008 template<
typename algorithmFPType, Method method>
1009 class DAAL_EXPORT Distributed<step5Master, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1016 Distributed(
size_t nClusters) : parameter(nClusters)
1026 Distributed(
const Distributed<step5Master, algorithmFPType, method> &other) : parameter(other.parameter), input(other.input)
1035 virtual int getMethod() const DAAL_C11_OVERRIDE{
return(
int)method; }
1041 ResultPtr getResult()
1050 services::Status setResult(
const ResultPtr& result)
1052 DAAL_CHECK(result, services::ErrorNullResult)
1054 _res = _result.get();
1055 return services::Status();
1062 DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
1064 return _partialResult;
1071 services::Status setPartialResult(
const DistributedStep5MasterPlusPlusPartialResultPtr& partialRes)
1073 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1074 _partialResult = partialRes;
1075 _pres = _partialResult.get();
1076 return services::Status();
1082 services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
1084 return services::Status();
1092 services::SharedPtr<Distributed<step5Master, algorithmFPType, method> > clone()
const
1094 return services::SharedPtr<Distributed<step5Master, algorithmFPType, method> >(cloneImpl());
1098 virtual Distributed<step5Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1100 return new Distributed<step5Master, algorithmFPType, method>(*this);
1103 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1105 _result.reset(
new Result());
1106 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int)method);
1107 _res = _result.get();
1111 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1113 _partialResult.reset(
new DistributedStep5MasterPlusPlusPartialResult());
1114 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int)method);
1115 _pres = _partialResult.get();
1119 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1121 return services::Status();
1126 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step5Master, algorithmFPType, method)(&_env);
1132 DistributedStep5MasterPlusPlusInput input;
1133 Parameter parameter;
1136 DistributedStep5MasterPlusPlusPartialResultPtr _partialResult;
1140 using interface1::DistributedContainer;
1141 using interface1::Distributed;
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::input
DistributedStep2LocalPlusPlusInput input
Definition: kmeans_init_distributed.h:726
daal::step2Local
Definition: daal_defines.h:147
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::Distributed
Distributed(const Distributed< step3Master, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:771
daal::algorithms::kmeans::init::data
Definition: kmeans_init_types.h:109
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::Distributed
Distributed(const Distributed< step2Local, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:643
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::input
DistributedStep5MasterPlusPlusInput input
Definition: kmeans_init_distributed.h:1132
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::Distributed
Distributed(size_t nClusters)
Definition: kmeans_init_distributed.h:761
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step5Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:1092
daal
Definition: algorithm_base_common.h:57
daal::step5Master
Definition: daal_defines.h:149
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:882
daal::algorithms::AnalysisContainerIface
Abstract interface class that provides virtual methods to access and run implementations of the analy...
Definition: analysis.h:79
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::input
DistributedStep3MasterPlusPlusInput input
Definition: kmeans_init_distributed.h:854
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep4LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:923
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::Distributed
Distributed(const Distributed< step5Master, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:1026
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::getPartialResult
DistributedStep4LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:914
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep3MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:795
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::checkFinalizeComputeParams
services::Status checkFinalizeComputeParams() DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:378
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:454
daal::algorithms::kmeans::init::interface1::Distributed< step2Master, algorithmFPType, method >::Distributed
Distributed(size_t nClusters, size_t offset=0)
Definition: kmeans_init_distributed.h:462
daal::services::ErrorNullPartialResult
Definition: error_indexes.h:131
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::input
DistributedStep4LocalPlusPlusInput input
Definition: kmeans_init_distributed.h:981
daal::algorithms::kmeans::init::interface1::DistributedStep2LocalPlusPlusParameter
Parameters for computing initial centroids for the K-Means algorithm.
Definition: kmeans_init_types.h:574
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::input
Input input
Definition: kmeans_init_distributed.h:428
daal::step3Master
Definition: daal_defines.h:148
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::getPartialResult
DistributedStep3MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:786
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:281
daal::distributed
Definition: daal_defines.h:132
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::Distributed
Distributed(const Distributed< step4Local, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:899
daal::algorithms::kmeans::init::interface1::Distributed< step2Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:548
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:625
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const PartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:367
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:754
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::Distributed
Distributed(const Distributed< step1Local, algorithmFPType, method > &other)
Definition: kmeans_init_distributed.h:321
daal::algorithms::kmeans::init::interface1::Distributed< step3Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step3Master, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:816
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:1009
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:301
daal::algorithms::kmeans::init::interface1::Parameter
Parameters for computing initial centroids for the K-Means algorithm.
Definition: kmeans_init_types.h:293
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:310
daal::step4Local
Definition: daal_defines.h:145
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:83
daal::algorithms::Analysis
Provides methods for execution of operations over data, such as computation of Summary Statistics est...
Definition: analysis.h:94
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::getPartialResult
DistributedStep5MasterPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:1062
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::parameter
Parameter parameter
Definition: kmeans_init_distributed.h:429
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::getResult
ResultPtr getResult()
Definition: kmeans_init_distributed.h:337
daal::step1Local
Definition: daal_defines.h:142
daal::algorithms::kmeans::init::interface1::Distributed< step2Master, algorithmFPType, method >::input
DistributedStep2MasterInput input
Definition: kmeans_init_distributed.h:595
daal::step2Master
Definition: daal_defines.h:143
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:688
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::parameter
DistributedStep2LocalPlusPlusParameter parameter
Definition: kmeans_init_distributed.h:727
daal::algorithms::implicit_als::training::offset
Definition: implicit_als_training_types.h:174
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::getPartialResult
DistributedStep2LocalPlusPlusPartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:658
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::getPartialResult
PartialResultPtr getPartialResult()
Definition: kmeans_init_distributed.h:358
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::setResult
services::Status setResult(const ResultPtr &result)
Definition: kmeans_init_distributed.h:346
daal::algorithms::kmeans::init::interface1::Distributed< step5Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep5MasterPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:1071
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: kmeans_init_distributed.h:331
daal::algorithms::kmeans::init::interface1::Distributed< step1Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step1Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:388
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedStep2LocalPlusPlusPartialResultPtr &partialRes)
Definition: kmeans_init_distributed.h:667
daal::services::ErrorNullResult
Definition: error_indexes.h:122
daal::algorithms::kmeans::init::interface1::Distributed< step2Local, algorithmFPType, method >::Distributed
Distributed(size_t nClusters, bool bFirstIteration)
Definition: kmeans_init_distributed.h:633
daal::algorithms::kmeans::init::interface1::Distributed< step4Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step4Local, algorithmFPType, method > > clone() const
Definition: kmeans_init_distributed.h:944