25 #ifndef __DBSCAN_DISTRIBUTED_H__
26 #define __DBSCAN_DISTRIBUTED_H__
28 #include "algorithms/algorithm.h"
29 #include "data_management/data/numeric_table.h"
30 #include "services/daal_defines.h"
31 #include "algorithms/dbscan/dbscan_types.h"
53 template<ComputeStep step,
typename algorithmFPType, Method method, CpuType cpu>
54 class DistributedContainer
61 template<
typename algorithmFPType, Method method, CpuType cpu>
62 class DistributedContainer<step1Local, algorithmFPType, method, cpu> :
public
63 TrainingContainerIface<distributed>
71 DistributedContainer(daal::services::Environment::env *daalEnv);
73 ~DistributedContainer();
79 services::Status compute() DAAL_C11_OVERRIDE;
84 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
91 template<
typename algorithmFPType, Method method, CpuType cpu>
92 class DistributedContainer<step2Local, algorithmFPType, method, cpu> :
public
93 TrainingContainerIface<distributed>
101 DistributedContainer(daal::services::Environment::env *daalEnv);
103 ~DistributedContainer();
109 services::Status compute() DAAL_C11_OVERRIDE;
114 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
122 template<
typename algorithmFPType, Method method, CpuType cpu>
123 class DistributedContainer<step3Local, algorithmFPType, method, cpu> :
public
124 TrainingContainerIface<distributed>
132 DistributedContainer(daal::services::Environment::env *daalEnv);
134 ~DistributedContainer();
140 services::Status compute() DAAL_C11_OVERRIDE;
145 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
153 template<
typename algorithmFPType, Method method, CpuType cpu>
154 class DistributedContainer<step4Local, algorithmFPType, method, cpu> :
public
155 TrainingContainerIface<distributed>
163 DistributedContainer(daal::services::Environment::env *daalEnv);
165 ~DistributedContainer();
171 services::Status compute() DAAL_C11_OVERRIDE;
176 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
184 template<
typename algorithmFPType, Method method, CpuType cpu>
185 class DistributedContainer<step5Local, algorithmFPType, method, cpu> :
public
186 TrainingContainerIface<distributed>
194 DistributedContainer(daal::services::Environment::env *daalEnv);
196 ~DistributedContainer();
202 services::Status compute() DAAL_C11_OVERRIDE;
207 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
215 template<
typename algorithmFPType, Method method, CpuType cpu>
216 class DistributedContainer<step6Local, algorithmFPType, method, cpu> :
public
217 TrainingContainerIface<distributed>
225 DistributedContainer(daal::services::Environment::env *daalEnv);
227 ~DistributedContainer();
233 services::Status compute() DAAL_C11_OVERRIDE;
238 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
246 template<
typename algorithmFPType, Method method, CpuType cpu>
247 class DistributedContainer<step7Master, algorithmFPType, method, cpu> :
public
248 TrainingContainerIface<distributed>
256 DistributedContainer(daal::services::Environment::env *daalEnv);
258 ~DistributedContainer();
264 services::Status compute() DAAL_C11_OVERRIDE;
269 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
277 template<
typename algorithmFPType, Method method, CpuType cpu>
278 class DistributedContainer<step8Local, algorithmFPType, method, cpu> :
public
279 TrainingContainerIface<distributed>
287 DistributedContainer(daal::services::Environment::env *daalEnv);
289 ~DistributedContainer();
295 services::Status compute() DAAL_C11_OVERRIDE;
300 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
308 template<
typename algorithmFPType, Method method, CpuType cpu>
309 class DistributedContainer<step9Master, algorithmFPType, method, cpu> :
public
310 TrainingContainerIface<distributed>
318 DistributedContainer(daal::services::Environment::env *daalEnv);
320 ~DistributedContainer();
326 services::Status compute() DAAL_C11_OVERRIDE;
331 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
339 template<
typename algorithmFPType, Method method, CpuType cpu>
340 class DistributedContainer<step10Local, algorithmFPType, method, cpu> :
public
341 TrainingContainerIface<distributed>
349 DistributedContainer(daal::services::Environment::env *daalEnv);
351 ~DistributedContainer();
357 services::Status compute() DAAL_C11_OVERRIDE;
362 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
370 template<
typename algorithmFPType, Method method, CpuType cpu>
371 class DistributedContainer<step11Local, algorithmFPType, method, cpu> :
public
372 TrainingContainerIface<distributed>
380 DistributedContainer(daal::services::Environment::env *daalEnv);
382 ~DistributedContainer();
388 services::Status compute() DAAL_C11_OVERRIDE;
393 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
401 template<
typename algorithmFPType, Method method, CpuType cpu>
402 class DistributedContainer<step12Local, algorithmFPType, method, cpu> :
public
403 TrainingContainerIface<distributed>
411 DistributedContainer(daal::services::Environment::env *daalEnv);
413 ~DistributedContainer();
419 services::Status compute() DAAL_C11_OVERRIDE;
424 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
432 template<
typename algorithmFPType, Method method, CpuType cpu>
433 class DistributedContainer<step13Local, algorithmFPType, method, cpu> :
public
434 TrainingContainerIface<distributed>
442 DistributedContainer(daal::services::Environment::env *daalEnv);
444 ~DistributedContainer();
450 services::Status compute() DAAL_C11_OVERRIDE;
455 services::Status finalizeCompute() DAAL_C11_OVERRIDE;
475 template<ComputeStep step,
typename algorithmFPType = DAAL_ALGORITHM_FP_TYPE, Method method = defaultDense>
476 class DAAL_EXPORT Distributed {};
491 template<
typename algorithmFPType, Method method>
492 class DAAL_EXPORT Distributed<step1Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
495 typedef algorithms::dbscan::DistributedInput<step1Local> InputType;
496 typedef algorithms::dbscan::Parameter ParameterType;
497 typedef algorithms::dbscan::DistributedPartialResultStep1 PartialResultType;
504 Distributed(
size_t blockIndex,
size_t nBlocks);
512 Distributed(
const Distributed<step1Local, algorithmFPType, method> &other);
523 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
529 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
535 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
541 DistributedPartialResultStep1Ptr getPartialResult()
543 return _partialResult;
549 services::Status setPartialResult(
const DistributedPartialResultStep1Ptr& partialRes)
551 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
552 _partialResult = partialRes;
553 _pres = _partialResult.get();
554 return services::Status();
562 services::SharedPtr<Distributed<step1Local, algorithmFPType, method> > clone()
const
564 return services::SharedPtr<Distributed<step1Local, algorithmFPType, method> >(cloneImpl());
568 virtual Distributed<step1Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
570 return new Distributed<step1Local, algorithmFPType, method>(*this);
573 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
575 return services::Status();
578 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
580 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
581 _pres = _partialResult.get();
585 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
587 return services::Status();
592 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step1Local, algorithmFPType, method)(&_env);
594 _partialResult.reset(
new PartialResultType());
601 DistributedPartialResultStep1Ptr _partialResult;
617 template<
typename algorithmFPType, Method method>
618 class DAAL_EXPORT Distributed<step2Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
621 typedef algorithms::dbscan::DistributedInput<step2Local> InputType;
622 typedef algorithms::dbscan::Parameter ParameterType;
623 typedef algorithms::dbscan::DistributedPartialResultStep2 PartialResultType;
630 Distributed(
size_t blockIndex,
size_t nBlocks);
638 Distributed(
const Distributed<step2Local, algorithmFPType, method> &other);
649 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
655 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
661 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
667 DistributedPartialResultStep2Ptr getPartialResult()
669 return _partialResult;
675 services::Status setPartialResult(
const DistributedPartialResultStep2Ptr& partialRes)
677 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
678 _partialResult = partialRes;
679 _pres = _partialResult.get();
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 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
707 _pres = _partialResult.get();
711 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
713 return services::Status();
718 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step2Local, algorithmFPType, method)(&_env);
720 _partialResult.reset(
new PartialResultType());
727 DistributedPartialResultStep2Ptr _partialResult;
743 template<
typename algorithmFPType, Method method>
744 class DAAL_EXPORT Distributed<step3Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
747 typedef algorithms::dbscan::DistributedInput<step3Local> InputType;
748 typedef algorithms::dbscan::Parameter ParameterType;
749 typedef algorithms::dbscan::DistributedPartialResultStep3 PartialResultType;
758 Distributed(
size_t leftBlocks,
size_t rightBlocks);
766 Distributed(
const Distributed<step3Local, algorithmFPType, method> &other);
777 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
783 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
789 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
795 DistributedPartialResultStep3Ptr getPartialResult()
797 return _partialResult;
803 services::Status setPartialResult(
const DistributedPartialResultStep3Ptr& partialRes)
805 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
806 _partialResult = partialRes;
807 _pres = _partialResult.get();
808 return services::Status();
816 services::SharedPtr<Distributed<step3Local, algorithmFPType, method> > clone()
const
818 return services::SharedPtr<Distributed<step3Local, algorithmFPType, method> >(cloneImpl());
822 virtual Distributed<step3Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
824 return new Distributed<step3Local, algorithmFPType, method>(*this);
827 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
829 return services::Status();
832 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
834 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
835 _pres = _partialResult.get();
839 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
841 return services::Status();
846 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step3Local, algorithmFPType, method)(&_env);
848 _partialResult.reset(
new PartialResultType());
855 DistributedPartialResultStep3Ptr _partialResult;
871 template<
typename algorithmFPType, Method method>
872 class DAAL_EXPORT Distributed<step4Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
875 typedef algorithms::dbscan::DistributedInput<step4Local> InputType;
876 typedef algorithms::dbscan::Parameter ParameterType;
877 typedef algorithms::dbscan::DistributedPartialResultStep4 PartialResultType;
886 Distributed(
size_t leftBlocks,
size_t rightBlocks);
894 Distributed(
const Distributed<step4Local, algorithmFPType, method> &other);
905 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
911 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
917 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
923 DistributedPartialResultStep4Ptr getPartialResult()
925 return _partialResult;
931 services::Status setPartialResult(
const DistributedPartialResultStep4Ptr& partialRes)
933 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
934 _partialResult = partialRes;
935 _pres = _partialResult.get();
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 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
963 _pres = _partialResult.get();
967 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
969 return services::Status();
974 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step4Local, algorithmFPType, method)(&_env);
976 _partialResult.reset(
new PartialResultType());
983 DistributedPartialResultStep4Ptr _partialResult;
999 template<
typename algorithmFPType, Method method>
1000 class DAAL_EXPORT Distributed<step5Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1003 typedef algorithms::dbscan::DistributedInput<step5Local> InputType;
1004 typedef algorithms::dbscan::Parameter ParameterType;
1005 typedef algorithms::dbscan::DistributedPartialResultStep5 PartialResultType;
1013 Distributed(
size_t blockIndex,
size_t nBlocks, algorithmFPType epsilon);
1021 Distributed(
const Distributed<step5Local, algorithmFPType, method> &other);
1032 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
1038 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
1044 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1050 DistributedPartialResultStep5Ptr getPartialResult()
1052 return _partialResult;
1058 services::Status setPartialResult(
const DistributedPartialResultStep5Ptr& partialRes)
1060 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1061 _partialResult = partialRes;
1062 _pres = _partialResult.get();
1063 return services::Status();
1071 services::SharedPtr<Distributed<step5Local, algorithmFPType, method> > clone()
const
1073 return services::SharedPtr<Distributed<step5Local, algorithmFPType, method> >(cloneImpl());
1077 virtual Distributed<step5Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1079 return new Distributed<step5Local, algorithmFPType, method>(*this);
1082 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1084 return services::Status();
1087 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1089 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1090 _pres = _partialResult.get();
1094 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1096 return services::Status();
1101 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step5Local, algorithmFPType, method)(&_env);
1103 _partialResult.reset(
new PartialResultType());
1110 DistributedPartialResultStep5Ptr _partialResult;
1126 template<
typename algorithmFPType, Method method>
1127 class DAAL_EXPORT Distributed<step6Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1130 typedef algorithms::dbscan::DistributedInput<step6Local> InputType;
1131 typedef algorithms::dbscan::Parameter ParameterType;
1132 typedef algorithms::dbscan::DistributedPartialResultStep6 PartialResultType;
1141 Distributed(
size_t blockIndex,
size_t nBlocks, algorithmFPType epsilon,
size_t minObservations);
1149 Distributed(
const Distributed<step6Local, algorithmFPType, method> &other);
1160 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
1166 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
1172 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1178 DistributedPartialResultStep6Ptr getPartialResult()
1180 return _partialResult;
1186 services::Status setPartialResult(
const DistributedPartialResultStep6Ptr& partialRes)
1188 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1189 _partialResult = partialRes;
1190 _pres = _partialResult.get();
1191 return services::Status();
1199 services::SharedPtr<Distributed<step6Local, algorithmFPType, method> > clone()
const
1201 return services::SharedPtr<Distributed<step6Local, algorithmFPType, method> >(cloneImpl());
1205 virtual Distributed<step6Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1207 return new Distributed<step6Local, algorithmFPType, method>(*this);
1210 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1212 return services::Status();
1215 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1217 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1218 _pres = _partialResult.get();
1222 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1224 return services::Status();
1229 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step6Local, algorithmFPType, method)(&_env);
1231 _partialResult.reset(
new PartialResultType());
1238 DistributedPartialResultStep6Ptr _partialResult;
1254 template<
typename algorithmFPType, Method method>
1255 class DAAL_EXPORT Distributed<step7Master, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1258 typedef algorithms::dbscan::DistributedInput<step7Master> InputType;
1259 typedef algorithms::dbscan::DistributedPartialResultStep7 PartialResultType;
1272 Distributed(
const Distributed<step7Master, algorithmFPType, method> &other);
1280 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1286 DistributedPartialResultStep7Ptr getPartialResult()
1288 return _partialResult;
1294 services::Status setPartialResult(
const DistributedPartialResultStep7Ptr& partialResult)
1296 DAAL_CHECK(partialResult, services::ErrorNullPartialResult)
1297 _partialResult = partialResult;
1298 _pres = _partialResult.get();
1299 return services::Status();
1307 services::SharedPtr<Distributed<step7Master, algorithmFPType, method> > clone()
const
1309 return services::SharedPtr<Distributed<step7Master, algorithmFPType, method> >(cloneImpl());
1315 virtual services::Status checkPartialResult() DAAL_C11_OVERRIDE
1317 return services::Status();
1321 virtual Distributed<step7Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1323 return new Distributed<step7Master, algorithmFPType, method>(*this);
1326 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1328 return services::Status();
1331 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1333 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1334 _pres = _partialResult.get();
1335 return services::Status();
1338 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1340 return services::Status();
1345 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step7Master, algorithmFPType, method)(&_env);
1347 _partialResult.reset(
new PartialResultType());
1354 DistributedPartialResultStep7Ptr _partialResult;
1370 template<
typename algorithmFPType, Method method>
1371 class DAAL_EXPORT Distributed<step8Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1374 typedef algorithms::dbscan::DistributedInput<step8Local> InputType;
1375 typedef algorithms::dbscan::Parameter ParameterType;
1376 typedef algorithms::dbscan::DistributedPartialResultStep8 PartialResultType;
1383 Distributed(
size_t blockIndex,
size_t nBlocks);
1391 Distributed(
const Distributed<step8Local, algorithmFPType, method> &other);
1402 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
1408 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
1414 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1420 DistributedPartialResultStep8Ptr getPartialResult()
1422 return _partialResult;
1428 services::Status setPartialResult(
const DistributedPartialResultStep8Ptr& partialRes)
1430 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1431 _partialResult = partialRes;
1432 _pres = _partialResult.get();
1433 return services::Status();
1441 services::SharedPtr<Distributed<step8Local, algorithmFPType, method> > clone()
const
1443 return services::SharedPtr<Distributed<step8Local, algorithmFPType, method> >(cloneImpl());
1447 virtual Distributed<step8Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1449 return new Distributed<step8Local, algorithmFPType, method>(*this);
1452 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1454 return services::Status();
1457 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1459 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1460 _pres = _partialResult.get();
1464 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1466 return services::Status();
1471 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step8Local, algorithmFPType, method)(&_env);
1473 _partialResult.reset(
new PartialResultType());
1480 DistributedPartialResultStep8Ptr _partialResult;
1496 template<
typename algorithmFPType, Method method>
1497 class DAAL_EXPORT Distributed<step9Master, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1500 typedef algorithms::dbscan::DistributedInput<step9Master> InputType;
1501 typedef algorithms::dbscan::DistributedResultStep9 ResultType;
1502 typedef algorithms::dbscan::DistributedPartialResultStep9 PartialResultType;
1515 Distributed(
const Distributed<step9Master, algorithmFPType, method> &other);
1523 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1529 DistributedResultStep9Ptr getResult()
1537 services::Status setResult(
const DistributedResultStep9Ptr& result)
1539 DAAL_CHECK(result, services::ErrorNullResult)
1541 _res = _result.get();
1542 return services::Status();
1549 DistributedPartialResultStep9Ptr getPartialResult()
1551 return _partialResult;
1557 services::Status setPartialResult(
const DistributedPartialResultStep9Ptr& partialRes)
1559 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1560 _partialResult = partialRes;
1561 _pres = _partialResult.get();
1562 return services::Status();
1570 services::SharedPtr<Distributed<step9Master, algorithmFPType, method> > clone()
const
1572 return services::SharedPtr<Distributed<step9Master, algorithmFPType, method> >(cloneImpl());
1576 virtual Distributed<step9Master, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1578 return new Distributed<step9Master, algorithmFPType, method>(*this);
1581 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1583 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int) method);
1584 _res = _result.get();
1585 return services::Status();
1588 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1590 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1591 _pres = _partialResult.get();
1595 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1597 return services::Status();
1602 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step9Master, algorithmFPType, method)(&_env);
1604 _result.reset(
new ResultType());
1605 _partialResult.reset(
new PartialResultType());
1612 DistributedResultStep9Ptr _result;
1613 DistributedPartialResultStep9Ptr _partialResult;
1629 template<
typename algorithmFPType, Method method>
1630 class DAAL_EXPORT Distributed<step10Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1633 typedef algorithms::dbscan::DistributedInput<step10Local> InputType;
1634 typedef algorithms::dbscan::Parameter ParameterType;
1635 typedef algorithms::dbscan::DistributedPartialResultStep10 PartialResultType;
1642 Distributed(
size_t blockIndex,
size_t nBlocks);
1650 Distributed(
const Distributed<step10Local, algorithmFPType, method> &other);
1661 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
1667 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
1673 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1679 DistributedPartialResultStep10Ptr getPartialResult()
1681 return _partialResult;
1687 services::Status setPartialResult(
const DistributedPartialResultStep10Ptr& partialRes)
1689 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1690 _partialResult = partialRes;
1691 _pres = _partialResult.get();
1692 return services::Status();
1700 services::SharedPtr<Distributed<step10Local, algorithmFPType, method> > clone()
const
1702 return services::SharedPtr<Distributed<step10Local, algorithmFPType, method> >(cloneImpl());
1706 virtual Distributed<step10Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1708 return new Distributed<step10Local, algorithmFPType, method>(*this);
1711 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1713 return services::Status();
1716 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1718 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1719 _pres = _partialResult.get();
1723 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1725 return services::Status();
1730 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step10Local, algorithmFPType, method)(&_env);
1732 _partialResult.reset(
new PartialResultType());
1739 DistributedPartialResultStep10Ptr _partialResult;
1755 template<
typename algorithmFPType, Method method>
1756 class DAAL_EXPORT Distributed<step11Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1759 typedef algorithms::dbscan::DistributedInput<step11Local> InputType;
1760 typedef algorithms::dbscan::Parameter ParameterType;
1761 typedef algorithms::dbscan::DistributedPartialResultStep11 PartialResultType;
1768 Distributed(
size_t blockIndex,
size_t nBlocks);
1776 Distributed(
const Distributed<step11Local, algorithmFPType, method> &other);
1787 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
1793 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
1799 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1805 DistributedPartialResultStep11Ptr getPartialResult()
1807 return _partialResult;
1813 services::Status setPartialResult(
const DistributedPartialResultStep11Ptr& partialRes)
1815 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1816 _partialResult = partialRes;
1817 _pres = _partialResult.get();
1818 return services::Status();
1826 services::SharedPtr<Distributed<step11Local, algorithmFPType, method> > clone()
const
1828 return services::SharedPtr<Distributed<step11Local, algorithmFPType, method> >(cloneImpl());
1832 virtual Distributed<step11Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1834 return new Distributed<step11Local, algorithmFPType, method>(*this);
1837 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1839 return services::Status();
1842 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1844 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1845 _pres = _partialResult.get();
1849 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1851 return services::Status();
1856 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step11Local, algorithmFPType, method)(&_env);
1858 _partialResult.reset(
new PartialResultType());
1865 DistributedPartialResultStep11Ptr _partialResult;
1881 template<
typename algorithmFPType, Method method>
1882 class DAAL_EXPORT Distributed<step12Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
1885 typedef algorithms::dbscan::DistributedInput<step12Local> InputType;
1886 typedef algorithms::dbscan::Parameter ParameterType;
1887 typedef algorithms::dbscan::DistributedPartialResultStep12 PartialResultType;
1894 Distributed(
size_t blockIndex,
size_t nBlocks);
1902 Distributed(
const Distributed<step12Local, algorithmFPType, method> &other);
1913 ParameterType& parameter() {
return *
static_cast<ParameterType*
>(_par); }
1919 const ParameterType& parameter()
const {
return *
static_cast<const ParameterType*
>(_par); }
1925 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
1931 DistributedPartialResultStep12Ptr getPartialResult()
1933 return _partialResult;
1939 services::Status setPartialResult(
const DistributedPartialResultStep12Ptr& partialRes)
1941 DAAL_CHECK(partialRes, services::ErrorNullPartialResult);
1942 _partialResult = partialRes;
1943 _pres = _partialResult.get();
1944 return services::Status();
1952 services::SharedPtr<Distributed<step12Local, algorithmFPType, method> > clone()
const
1954 return services::SharedPtr<Distributed<step12Local, algorithmFPType, method> >(cloneImpl());
1958 virtual Distributed<step12Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
1960 return new Distributed<step12Local, algorithmFPType, method>(*this);
1963 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
1965 return services::Status();
1968 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
1970 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
1971 _pres = _partialResult.get();
1975 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
1977 return services::Status();
1982 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step12Local, algorithmFPType, method)(&_env);
1984 _partialResult.reset(
new PartialResultType());
1991 DistributedPartialResultStep12Ptr _partialResult;
2007 template<
typename algorithmFPType, Method method>
2008 class DAAL_EXPORT Distributed<step13Local, algorithmFPType, method> :
public daal::algorithms::Analysis<distributed>
2011 typedef algorithms::dbscan::DistributedInput<step13Local> InputType;
2012 typedef algorithms::dbscan::DistributedResultStep13 ResultType;
2013 typedef algorithms::dbscan::DistributedPartialResultStep13 PartialResultType;
2026 Distributed(
const Distributed<step13Local, algorithmFPType, method> &other);
2034 virtual int getMethod() const DAAL_C11_OVERRIDE {
return(
int) method; }
2040 DistributedResultStep13Ptr getResult()
2048 services::Status setResult(
const DistributedResultStep13Ptr& result)
2050 DAAL_CHECK(result, services::ErrorNullResult)
2052 _res = _result.get();
2053 return services::Status();
2060 DistributedPartialResultStep13Ptr getPartialResult()
2062 return _partialResult;
2068 services::Status setPartialResult(
const DistributedPartialResultStep13Ptr& partialResult)
2070 DAAL_CHECK(partialResult, services::ErrorNullPartialResult)
2071 _partialResult = partialResult;
2072 _pres = _partialResult.get();
2073 return services::Status();
2081 services::SharedPtr<Distributed<step13Local, algorithmFPType, method> > clone()
const
2083 return services::SharedPtr<Distributed<step13Local, algorithmFPType, method> >(cloneImpl());
2089 virtual services::Status checkPartialResult() DAAL_C11_OVERRIDE
2091 return services::Status();
2095 virtual Distributed<step13Local, algorithmFPType, method> * cloneImpl() const DAAL_C11_OVERRIDE
2097 return new Distributed<step13Local, algorithmFPType, method>(*this);
2100 virtual services::Status allocateResult() DAAL_C11_OVERRIDE
2102 services::Status s = _result->allocate<algorithmFPType>(_pres, _par, (int) method);
2103 _res = _result.get();
2104 return services::Status();
2107 virtual services::Status allocatePartialResult() DAAL_C11_OVERRIDE
2109 services::Status s = _partialResult->allocate<algorithmFPType>(&input, _par, (int) method);
2110 _pres = _partialResult.get();
2111 return services::Status();
2114 virtual services::Status initializePartialResult() DAAL_C11_OVERRIDE
2116 return services::Status();
2121 Analysis<distributed>::_ac =
new __DAAL_ALGORITHM_CONTAINER(distributed, DistributedContainer, step13Local, algorithmFPType, method)(&_env);
2123 _result.reset(
new ResultType());
2124 _partialResult.reset(
new PartialResultType());
2131 DistributedResultStep13Ptr _result;
2132 DistributedPartialResultStep13Ptr _partialResult;
2137 using interface1::DistributedContainer;
2138 using interface1::Distributed;
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::setResult
services::Status setResult(const DistributedResultStep13Ptr &result)
Definition: dbscan_distributed.h:2048
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1799
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep9Ptr &partialRes)
Definition: dbscan_distributed.h:1557
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:1667
daal::step1Local
Definition: daal_defines.h:123
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step12Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1952
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep7Ptr getPartialResult()
Definition: dbscan_distributed.h:1286
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:789
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep13Ptr &partialResult)
Definition: dbscan_distributed.h:2068
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the second step of the distributed processing mode...
Definition: dbscan_distributed.h:618
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep6Ptr &partialRes)
Definition: dbscan_distributed.h:1186
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep4Ptr &partialRes)
Definition: dbscan_distributed.h:931
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:1919
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:852
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:1787
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1925
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:529
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:1793
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:980
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:783
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1988
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep12Ptr getPartialResult()
Definition: dbscan_distributed.h:1931
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep10Ptr &partialRes)
Definition: dbscan_distributed.h:1687
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:598
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:649
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1673
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep8Ptr &partialRes)
Definition: dbscan_distributed.h:1428
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1351
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1736
daal::step12Local
Definition: daal_defines.h:139
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step8Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1441
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:2128
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep2Ptr &partialRes)
Definition: dbscan_distributed.h:675
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step1Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:562
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:911
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1862
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep6Ptr getPartialResult()
Definition: dbscan_distributed.h:1178
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the fifth step of the distributed processing mode...
Definition: dbscan_distributed.h:1000
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1280
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:523
daal::step11Local
Definition: daal_defines.h:138
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step6Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1199
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step7Master, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1307
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:661
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step11Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1826
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step13Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:2081
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep9Ptr getPartialResult()
Definition: dbscan_distributed.h:1549
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep11Ptr &partialRes)
Definition: dbscan_distributed.h:1813
daal::algorithms::dbscan::interface1::Distributed
Computes the results of the DBSCAN algorithm in the distributed processing mode.
Definition: dbscan_distributed.h:476
daal::step13Local
Definition: daal_defines.h:140
daal::step3Local
Definition: daal_defines.h:125
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1414
daal::services::ErrorNullResult
Definition: error_indexes.h:98
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the eighth step of the distributed processing mode...
Definition: dbscan_distributed.h:1882
daal::step8Local
Definition: daal_defines.h:135
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the seventh step of the distributed processing mode...
Definition: dbscan_distributed.h:1497
daal::step7Master
Definition: daal_defines.h:134
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:1402
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1172
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep5Ptr getPartialResult()
Definition: dbscan_distributed.h:1050
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::step9Master
Definition: daal_defines.h:136
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::getResult
DistributedResultStep9Ptr getResult()
Definition: dbscan_distributed.h:1529
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1523
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step3Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:816
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:535
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:1160
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1044
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:1166
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the tenth step of the distributed processing mode...
Definition: dbscan_distributed.h:1630
daal::step4Local
Definition: daal_defines.h:126
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the seventh step of the distributed processing mode...
Definition: dbscan_distributed.h:1255
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step4Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:944
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >::checkPartialResult
virtual services::Status checkPartialResult() DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:1315
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:1408
daal::algorithms::dbscan::interface1::DistributedContainer
Class containing methods to compute the result of DBSCAN algorithm in the distributed processing mode...
Definition: dbscan_distributed.h:54
daal::algorithms::dbscan::interface1::Distributed< step7Master, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep7Ptr &partialResult)
Definition: dbscan_distributed.h:1294
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the first step of the distributed processing mode...
Definition: dbscan_distributed.h:492
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1477
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep3Ptr getPartialResult()
Definition: dbscan_distributed.h:795
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep5Ptr &partialRes)
Definition: dbscan_distributed.h:1058
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep12Ptr &partialRes)
Definition: dbscan_distributed.h:1939
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the third step of the distributed processing mode...
Definition: dbscan_distributed.h:744
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1235
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1609
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep10Ptr getPartialResult()
Definition: dbscan_distributed.h:1679
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep4Ptr getPartialResult()
Definition: dbscan_distributed.h:923
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep2Ptr getPartialResult()
Definition: dbscan_distributed.h:667
daal::step5Local
Definition: daal_defines.h:132
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:1032
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::setResult
services::Status setResult(const DistributedResultStep9Ptr &result)
Definition: dbscan_distributed.h:1537
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the seventh step of the distributed processing mode...
Definition: dbscan_distributed.h:2008
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep8Ptr getPartialResult()
Definition: dbscan_distributed.h:1420
daal::step10Local
Definition: daal_defines.h:137
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step2Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:688
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:655
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the eleventh step of the distributed processing mode...
Definition: dbscan_distributed.h:1756
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::parameter
const ParameterType & parameter() const
Definition: dbscan_distributed.h:1038
daal::algorithms::Analysis
Provides methods for execution of operations over data, such as computation of Summary Statistics est...
Definition: analysis.h:70
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::getResult
DistributedResultStep13Ptr getResult()
Definition: dbscan_distributed.h:2040
daal::algorithms::dbscan::interface1::Distributed< step8Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the eighth step of the distributed processing mode...
Definition: dbscan_distributed.h:1371
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:777
daal::step6Local
Definition: daal_defines.h:133
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:917
daal::services::ErrorNullPartialResult
Definition: error_indexes.h:107
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the fourth step of the distributed processing mode...
Definition: dbscan_distributed.h:872
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:1107
daal::algorithms::dbscan::interface1::Distributed< step12Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:1913
daal::distributed
Definition: daal_defines.h:113
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep13Ptr getPartialResult()
Definition: dbscan_distributed.h:2060
daal::algorithms::TrainingContainerIface
Abstract interface class that provides virtual methods to access and run implementations of the model...
Definition: training.h:52
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep1Ptr getPartialResult()
Definition: dbscan_distributed.h:541
daal::algorithms::dbscan::interface1::Distributed< step4Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:905
daal::algorithms::dbscan::interface1::Distributed< step11Local, algorithmFPType, method >::getPartialResult
DistributedPartialResultStep11Ptr getPartialResult()
Definition: dbscan_distributed.h:1805
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::checkPartialResult
virtual services::Status checkPartialResult() DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:2089
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::parameter
ParameterType & parameter()
Definition: dbscan_distributed.h:1661
daal::algorithms::dbscan::interface1::Distributed< step13Local, algorithmFPType, method >::getMethod
virtual int getMethod() const DAAL_C11_OVERRIDE
Definition: dbscan_distributed.h:2034
daal::step2Local
Definition: daal_defines.h:128
daal::algorithms::dbscan::interface1::Distributed< step1Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep1Ptr &partialRes)
Definition: dbscan_distributed.h:549
daal::algorithms::dbscan::interface1::Distributed< step6Local, algorithmFPType, method >
Computes the results of the DBSCAN algorithm in the sixth step of the distributed processing mode...
Definition: dbscan_distributed.h:1127
daal::algorithms::dbscan::interface1::Distributed< step5Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step5Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1071
daal::algorithms::dbscan::interface1::Distributed< step2Local, algorithmFPType, method >::input
InputType input
Definition: dbscan_distributed.h:724
daal::algorithms::dbscan::interface1::Distributed< step9Master, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step9Master, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1570
daal::algorithms::dbscan::interface1::Distributed< step10Local, algorithmFPType, method >::clone
services::SharedPtr< Distributed< step10Local, algorithmFPType, method > > clone() const
Definition: dbscan_distributed.h:1700
daal::algorithms::dbscan::interface1::Distributed< step3Local, algorithmFPType, method >::setPartialResult
services::Status setPartialResult(const DistributedPartialResultStep3Ptr &partialRes)
Definition: dbscan_distributed.h:803