22 #ifndef __DATA_SOURCE_H__
23 #define __DATA_SOURCE_H__
26 #include "data_management/data/data_dictionary.h"
27 #include "data_management/data/numeric_table.h"
28 #include "data_management/data/homogen_numeric_table.h"
29 #include "data_management/data/aos_numeric_table.h"
30 #include "data_management/data/soa_numeric_table.h"
32 #include "data_management/data_source/data_source_utils.h"
36 namespace data_management
69 enum DictionaryCreationFlag
71 notDictionaryFromContext = 1,
72 doDictionaryFromContext = 2
79 enum NumericTableAllocationFlag
81 notAllocateNumericTable = 1,
82 doAllocateNumericTable = 2
90 DAAL_DEPRECATED_VIRTUAL
virtual DataSourceDictionary *getDictionary() = 0;
96 virtual DataSourceDictionaryPtr getDictionarySharedPtr() = 0;
101 virtual services::Status setDictionary(DataSourceDictionary *dict) = 0;
106 virtual services::Status createDictionaryFromContext() = 0;
112 virtual DataSourceStatus getStatus() = 0;
118 virtual size_t getNumberOfColumns() = 0;
124 virtual size_t getNumericTableNumberOfColumns() = 0;
130 virtual size_t getNumberOfAvailableRows() = 0;
135 virtual services::Status allocateNumericTable() = 0;
141 virtual NumericTablePtr getNumericTable() = 0;
146 virtual void freeNumericTable() = 0;
152 virtual size_t loadDataBlock(
size_t maxRows) = 0;
160 virtual size_t loadDataBlock(
size_t maxRows,
size_t rowOffset,
size_t fullRows) = 0;
167 virtual size_t loadDataBlock(
size_t maxRows, NumericTable *nt) = 0;
176 virtual size_t loadDataBlock(
size_t maxRows,
size_t rowOffset,
size_t fullRows, NumericTable *nt) = 0;
181 virtual size_t loadDataBlock() = 0;
187 virtual size_t loadDataBlock(NumericTable *nt) = 0;
194 class DataSource :
public DataSourceIface
197 DataSource() : _dict(), _errors(
new services::ErrorCollection()), _initialMaxRows(10), _autoNumericTableFlag(doAllocateNumericTable), _autoDictionaryFlag(doDictionaryFromContext) {}
199 virtual ~DataSource() {}
201 DAAL_DEPRECATED_VIRTUAL DataSourceDictionary *getDictionary() DAAL_C11_OVERRIDE
203 services::Status s = checkDictionary();
209 DataSourceDictionaryPtr getDictionarySharedPtr() DAAL_C11_OVERRIDE
211 services::Status s = checkDictionary();
213 return DataSourceDictionaryPtr();
217 services::Status setDictionary(DataSourceDictionary *dict) DAAL_C11_OVERRIDE
220 return services::throwIfPossible(services::Status(services::ErrorDictionaryAlreadyAvailable));
222 services::Status s = dict->checkDictionary();
224 return services::throwIfPossible(s);
226 _dict.reset(dict, services::EmptyDeleter());
227 return services::Status();
230 services::Status createDictionaryFromContext() DAAL_C11_OVERRIDE
232 return services::throwIfPossible(services::Status(services::ErrorMethodNotSupported));
235 size_t loadDataBlock(
size_t maxRows) DAAL_C11_OVERRIDE
237 services::Status s = checkDictionary();
238 s.add(checkNumericTable());
241 this->_status.add(services::throwIfPossible(s));
244 return loadDataBlock(maxRows, this->DataSource::_spnt.
get());
247 size_t loadDataBlock(
size_t maxRows, NumericTable *nt) DAAL_C11_OVERRIDE
249 this->_status.add(services::throwIfPossible(services::ErrorMethodNotSupported));
253 size_t loadDataBlock(
size_t maxRows,
size_t rowOffset,
size_t fullRows) DAAL_C11_OVERRIDE
255 services::Status s = checkDictionary();
257 s.add(checkNumericTable());
260 this->_status.add(services::throwIfPossible(s));
263 return loadDataBlock(maxRows, rowOffset, fullRows, this->DataSource::_spnt.
get());
266 size_t loadDataBlock(
size_t maxRows,
size_t rowOffset,
size_t fullRows, NumericTable *nt) DAAL_C11_OVERRIDE
268 this->_status.add(services::throwIfPossible(services::ErrorMethodNotSupported));
272 size_t loadDataBlock() DAAL_C11_OVERRIDE
274 services::Status s = checkDictionary();
277 s.add(checkNumericTable());
281 this->_status.add(services::throwIfPossible(s));
284 return loadDataBlock(this->DataSource::_spnt.
get());
287 size_t loadDataBlock(NumericTable *nt) DAAL_C11_OVERRIDE
289 this->_status.add(services::throwIfPossible(services::ErrorMethodNotSupported));
293 NumericTablePtr getNumericTable() DAAL_C11_OVERRIDE
299 size_t getNumberOfColumns() DAAL_C11_OVERRIDE
302 return _dict ? _dict->getNumberOfFeatures() : 0;
309 services::Status status()
const
311 services::Status s = _status;
322 DAAL_DEPRECATED services::SharedPtr<services::ErrorCollection> getErrors()
324 return status().getCollection();
327 virtual size_t getNumericTableNumberOfColumns() DAAL_C11_OVERRIDE
329 return getNumberOfColumns();
333 DataSourceDictionaryPtr _dict;
334 NumericTablePtr _spnt;
336 NumericTableAllocationFlag _autoNumericTableFlag;
337 DictionaryCreationFlag _autoDictionaryFlag;
338 services::Status _status;
339 services::SharedPtr<services::ErrorCollection> _errors;
340 size_t _initialMaxRows;
345 services::Status checkNumericTable()
347 if( _spnt.get() == NULL )
349 if( _autoNumericTableFlag == notAllocateNumericTable )
350 return services::throwIfPossible(services::Status(services::ErrorNumericTableNotAllocated));
351 return allocateNumericTable();
353 return services::Status();
359 services::Status checkDictionary()
363 if( _autoDictionaryFlag == notDictionaryFromContext )
364 return services::throwIfPossible(services::Status(services::ErrorDictionaryNotAvailable));
365 return createDictionaryFromContext();
367 return services::Status();
379 template<
typename NumericTableType> services::Status allocateNumericTableImpl(services::SharedPtr<NumericTableType> &nt);
390 template<
typename FPType> services::Status allocateNumericTableImpl(services::SharedPtr<HomogenNumericTable<FPType> > &nt);
392 size_t getStructureSize()
394 size_t structureSize = 0;
395 size_t nFeatures = _dict->getNumberOfFeatures();
396 for(
size_t i = 0; i < nFeatures; i++)
398 features::IndexNumType indexNumType = (*_dict)[i].ntFeature.indexType;
399 structureSize += (*_dict)[i].ntFeature.typeSize;
401 return structureSize;
404 virtual services::Status setNumericTableDictionary(NumericTablePtr nt)
406 if (!nt)
return services::throwIfPossible(services::Status(services::ErrorNullNumericTable));
407 NumericTableDictionaryPtr ntDict = nt->getDictionarySharedPtr();
408 if (!ntDict)
return services::throwIfPossible(services::Status(services::ErrorDictionaryNotAvailable));
410 size_t nFeatures = ntDict->getNumberOfFeatures();
412 for(
size_t i = 0; i < nFeatures; i++)
414 (*ntDict)[i] = (*_dict)[i].ntFeature;
416 return services::Status();
420 template<
typename NumericTableType>
421 inline services::Status DataSource::allocateNumericTableImpl(services::SharedPtr<NumericTableType> &nt)
423 nt = services::SharedPtr<NumericTableType>();
424 return services::Status();
428 inline services::Status DataSource::allocateNumericTableImpl(AOSNumericTablePtr &nt)
430 size_t nFeatures = _dict->getNumberOfFeatures();
431 size_t structureSize = getStructureSize();
433 nt = AOSNumericTable::create(structureSize, nFeatures, 0, &s);
435 s |= setNumericTableDictionary(nt);
440 inline services::Status DataSource::allocateNumericTableImpl(SOANumericTablePtr &nt)
442 nt = SOANumericTablePtr();
443 return services::Status();
446 template<
typename FPType>
447 inline services::Status DataSource::allocateNumericTableImpl(services::SharedPtr<HomogenNumericTable<FPType> > &nt)
449 size_t nFeatures = getNumericTableNumberOfColumns();
451 nt = HomogenNumericTable<FPType>::create(nFeatures, 0, NumericTableIface::doNotAllocate, &s);
453 s |= setNumericTableDictionary(nt);
462 template<
typename _numericTableType,
typename _summaryStatisticsType = DAAL_SUMMARY_STATISTICS_TYPE >
463 class DataSourceTemplate :
public DataSource
466 typedef _numericTableType numericTableType;
469 DataSourceTemplate( NumericTableAllocationFlag doAllocateNumericTable,
470 DictionaryCreationFlag doCreateDictionaryFromContext ) : DataSource()
472 DataSource::_autoNumericTableFlag = doAllocateNumericTable;
473 DataSource::_autoDictionaryFlag = doCreateDictionaryFromContext;
476 virtual ~DataSourceTemplate() {}
478 virtual void freeNumericTable() DAAL_C11_OVERRIDE
480 _spnt = NumericTablePtr();
483 virtual services::Status allocateNumericTable() DAAL_C11_OVERRIDE
485 if( _spnt.get() != NULL )
486 return services::throwIfPossible(services::Status(services::ErrorNumericTableAlreadyAllocated));
488 services::Status s = checkDictionary();
492 services::SharedPtr<numericTableType> nt;
494 s |= allocateNumericTableImpl( nt );
497 services::SharedPtr<HomogenNumericTable<_summaryStatisticsType> > ssNt;
499 s |= allocateNumericTableImpl( ssNt );
500 _spnt->basicStatistics.set(NumericTable::minimum, ssNt);
502 s |= allocateNumericTableImpl( ssNt );
503 _spnt->basicStatistics.set(NumericTable::maximum, ssNt);
505 s |= allocateNumericTableImpl( ssNt );
506 _spnt->basicStatistics.set(NumericTable::sum, ssNt);
508 s |= allocateNumericTableImpl( ssNt );
509 _spnt->basicStatistics.set(NumericTable::sumSquares, ssNt);
514 services::Status resizeNumericTableImpl(
const size_t linesToLoad, NumericTable* nt)
517 return services::Status(services::ErrorNullInputNumericTable);
520 return services::Status(services::ErrorDictionaryNotAvailable);
522 size_t nFeatures = getNumericTableNumberOfColumns();
524 if (nt->getNumberOfColumns() < nFeatures) {
525 nt->getDictionarySharedPtr()->setNumberOfFeatures(nFeatures);
529 nt->resize(linesToLoad);
531 const size_t nCols = nt->getNumberOfColumns();
533 nt->allocateBasicStatistics();
535 NumericTablePtr ntMin = nt->basicStatistics.get(NumericTable::minimum );
536 NumericTablePtr ntMax = nt->basicStatistics.get(NumericTable::maximum );
537 NumericTablePtr ntSum = nt->basicStatistics.get(NumericTable::sum );
538 NumericTablePtr ntSumSq = nt->basicStatistics.get(NumericTable::sumSquares);
540 if( ntMin->getNumberOfColumns() != nCols || ntMin->getNumberOfRows() != 1 )
542 if( ntMin->getNumberOfColumns() != nCols )
544 ntMin->getDictionarySharedPtr()->setNumberOfFeatures(nCols);
549 if( ntMax->getNumberOfColumns() != nCols || ntMax->getNumberOfRows() != 1 )
551 if( ntMax->getNumberOfColumns() != nCols )
553 ntMax->getDictionarySharedPtr()->setNumberOfFeatures(nCols);
558 if( ntSum->getNumberOfColumns() != nCols || ntSum->getNumberOfRows() != 1 )
560 if( ntSum->getNumberOfColumns() != nCols )
562 ntSum->getDictionarySharedPtr()->setNumberOfFeatures(nCols);
567 if( ntSumSq->getNumberOfColumns() != nCols || ntSumSq->getNumberOfRows() != 1 )
569 if( ntSumSq->getNumberOfColumns() != nCols )
571 ntSumSq->getDictionarySharedPtr()->setNumberOfFeatures(nCols);
575 return services::Status();
578 services::Status updateStatistics(
size_t ntRowIndex, NumericTable *nt,
size_t offset = 0)
581 return services::Status(services::ErrorNullInputNumericTable);
583 NumericTablePtr ntMin = nt->basicStatistics.get(NumericTable::minimum );
584 NumericTablePtr ntMax = nt->basicStatistics.get(NumericTable::maximum );
585 NumericTablePtr ntSum = nt->basicStatistics.get(NumericTable::sum );
586 NumericTablePtr ntSumSq = nt->basicStatistics.get(NumericTable::sumSquares);
588 BlockDescriptor<_summaryStatisticsType> blockMin;
589 BlockDescriptor<_summaryStatisticsType> blockMax;
590 BlockDescriptor<_summaryStatisticsType> blockSum;
591 BlockDescriptor<_summaryStatisticsType> blockSumSq;
593 ntMin->getBlockOfRows(0, 1, readWrite, blockMin);
594 ntMax->getBlockOfRows(0, 1, readWrite, blockMax);
595 ntSum->getBlockOfRows(0, 1, readWrite, blockSum);
596 ntSumSq->getBlockOfRows(0, 1, readWrite, blockSumSq);
598 _summaryStatisticsType *minimum = blockMin.getBlockPtr();
599 _summaryStatisticsType *maximum = blockMax.getBlockPtr();
600 _summaryStatisticsType *sum = blockSum.getBlockPtr();
601 _summaryStatisticsType *sumSquares = blockSumSq.getBlockPtr();
603 size_t nCols = nt->getNumberOfColumns();
605 if( minimum == NULL || maximum == NULL || sum == NULL || sumSquares == NULL )
607 ntMin->releaseBlockOfRows(blockMin);
608 ntMax->releaseBlockOfRows(blockMax);
609 ntSum->releaseBlockOfRows(blockSum);
610 ntSumSq->releaseBlockOfRows(blockSumSq);
611 return services::Status(services::ErrorIncorrectInputNumericTable);
614 BlockDescriptor<_summaryStatisticsType> block;
615 nt->getBlockOfRows( ntRowIndex + offset, 1, readOnly, block );
616 _summaryStatisticsType *row = block.getBlockPtr();
618 if( ntRowIndex != 0 )
620 for(
size_t i = 0; i < nCols; i++ )
622 if( minimum[i] > row[i] ) { minimum[i] = row[i]; }
623 if( maximum[i] < row[i] ) { maximum[i] = row[i]; }
625 sumSquares[i] += row[i] * row[i];
630 for(
size_t i = 0; i < nCols; i++ )
635 sumSquares[i] = row[i] * row[i];
639 nt->releaseBlockOfRows( block );
640 ntMin->releaseBlockOfRows( blockMin );
641 ntMax->releaseBlockOfRows( blockMax );
642 ntSum->releaseBlockOfRows( blockSum );
643 ntSumSq->releaseBlockOfRows( blockSumSq );
644 return services::Status();
647 services::Status combineSingleStatistics(NumericTable *ntSrc, NumericTable *ntDst,
bool wasEmpty, NumericTable::BasicStatisticsId
id)
649 if( ntSrc == NULL || ntDst == NULL )
650 return services::Status(services::ErrorNullInputNumericTable);
652 NumericTablePtr ntSrcStat = ntSrc->basicStatistics.get(
id);
653 NumericTablePtr ntDstStat = ntDst->basicStatistics.get(
id);
655 BlockDescriptor<_summaryStatisticsType> blockSrc;
656 BlockDescriptor<_summaryStatisticsType> blockDst;
658 ntSrcStat->getBlockOfRows(0, 1, readOnly, blockSrc);
659 ntDstStat->getBlockOfRows(0, 1, readWrite, blockDst);
661 const _summaryStatisticsType *src = blockSrc.getBlockPtr();
662 _summaryStatisticsType *dst = blockDst.getBlockPtr();
664 if( src == NULL || dst == NULL )
666 ntSrcStat->releaseBlockOfRows(blockSrc);
667 ntDstStat->releaseBlockOfRows(blockDst);
668 return services::Status(services::ErrorIncorrectInputNumericTable);
671 const size_t nColsSrc = ntSrc->getNumberOfColumns();
672 const size_t nCols = ntDst->getNumberOfColumns();
674 if (nCols != nColsSrc)
676 ntSrcStat->releaseBlockOfRows(blockSrc);
677 ntDstStat->releaseBlockOfRows(blockDst);
678 return services::Status(services::ErrorIncorrectInputNumericTable);
683 for(
size_t i = 0; i < nCols; i++ )
690 if (
id == NumericTable::minimum)
692 for(
size_t i = 0; i < nCols; i++ )
701 if (
id == NumericTable::maximum)
703 for(
size_t i = 0; i < nCols; i++ )
712 if (
id == NumericTable::sum)
714 for(
size_t i = 0; i < nCols; i++ )
720 if (
id == NumericTable::sumSquares)
722 for(
size_t i = 0; i < nCols; i++ )
729 ntSrcStat->releaseBlockOfRows( blockSrc );
730 ntDstStat->releaseBlockOfRows( blockDst );
731 return services::Status();
734 services::Status combineStatistics(NumericTable *ntSrc, NumericTable *ntDst,
bool wasEmpty)
737 s.add(combineSingleStatistics(ntSrc, ntDst, wasEmpty, NumericTable::minimum));
738 s.add(combineSingleStatistics(ntSrc, ntDst, wasEmpty, NumericTable::maximum));
739 s.add(combineSingleStatistics(ntSrc, ntDst, wasEmpty, NumericTable::sum));
740 s.add(combineSingleStatistics(ntSrc, ntDst, wasEmpty, NumericTable::sumSquares));
748 using interface1::DataSourceIface;
749 using interface1::DataSource;
750 using interface1::DataSourceTemplate;
daal::data_management::interface1::DataSource::loadDataBlock
size_t loadDataBlock(size_t maxRows, size_t rowOffset, size_t fullRows) DAAL_C11_OVERRIDE
Definition: data_source.h:253
daal::data_management::interface1::DataSource::getDictionary
DAAL_DEPRECATED_VIRTUAL DataSourceDictionary * getDictionary() DAAL_C11_OVERRIDE
Definition: data_source.h:201
daal::data_management::interface1::DataSource::checkDictionary
services::Status checkDictionary()
Definition: data_source.h:359
daal::services::ErrorDictionaryAlreadyAvailable
Definition: error_indexes.h:152
daal::services::ErrorNullInputNumericTable
Definition: error_indexes.h:81
daal
Definition: algorithm_base_common.h:31
daal::services::ErrorIncorrectInputNumericTable
Definition: error_indexes.h:75
daal::data_management::interface1::DataSourceIface
Abstract interface class that defines the interface for a data management component responsible for r...
Definition: data_source.h:50
daal::data_management::interface1::DataSourceIface::allocateNumericTable
virtual services::Status allocateNumericTable()=0
daal::services::ErrorNumericTableNotAllocated
Definition: error_indexes.h:156
daal::data_management::interface1::DataSource::status
services::Status status() const
Definition: data_source.h:309
daal::data_management::interface1::DataSourceIface::createDictionaryFromContext
virtual services::Status createDictionaryFromContext()=0
daal::data_management::interface1::DataSourceIface::getNumberOfAvailableRows
virtual size_t getNumberOfAvailableRows()=0
daal::data_management::interface1::NumericTable::getDictionarySharedPtr
virtual NumericTableDictionaryPtr getDictionarySharedPtr() const DAAL_C11_OVERRIDE
Definition: numeric_table.h:633
daal::data_management::interface1::DataSourceIface::loadDataBlock
virtual size_t loadDataBlock()=0
daal::data_management::interface1::DataSourceIface::DictionaryCreationFlag
DictionaryCreationFlag
Specifies whether a Data Dictionary is created from the context of a Data Source. ...
Definition: data_source.h:69
daal::data_management::interface1::DataSource::getNumericTable
NumericTablePtr getNumericTable() DAAL_C11_OVERRIDE
Definition: data_source.h:293
daal::algorithms::low_order_moments::maximum
Definition: low_order_moments_types.h:88
daal::data_management::interface1::DataSource
Implements the abstract DataSourceIface interface.
Definition: data_source.h:194
daal::data_management::interface1::DataSourceIface::notAllocateNumericTable
Definition: data_source.h:81
daal::data_management::interface1::NumericTable::getNumberOfColumns
size_t getNumberOfColumns() const
Definition: numeric_table.h:652
daal::data_management::interface1::DataSourceIface::freeNumericTable
virtual void freeNumericTable()=0
daal::algorithms::low_order_moments::minimum
Definition: low_order_moments_types.h:87
daal::data_management::interface1::DataSource::getDictionarySharedPtr
DataSourceDictionaryPtr getDictionarySharedPtr() DAAL_C11_OVERRIDE
Definition: data_source.h:209
daal::data_management::interface1::DataSource::getNumberOfColumns
size_t getNumberOfColumns() DAAL_C11_OVERRIDE
Definition: data_source.h:299
daal::data_management::interface1::DataSource::loadDataBlock
size_t loadDataBlock(size_t maxRows) DAAL_C11_OVERRIDE
Definition: data_source.h:235
daal::data_management::interface1::DataSourceIface::getNumericTable
virtual NumericTablePtr getNumericTable()=0
daal::data_management::interface1::DataSourceTemplate::allocateNumericTable
virtual services::Status allocateNumericTable() DAAL_C11_OVERRIDE
Definition: data_source.h:483
daal::data_management::interface1::DataSource::loadDataBlock
size_t loadDataBlock(NumericTable *nt) DAAL_C11_OVERRIDE
Definition: data_source.h:287
daal::data_management::interface1::DataSourceIface::doAllocateNumericTable
Definition: data_source.h:82
daal::data_management::interface1::DataSourceTemplate
Implements the abstract DataSourceIface interface.
Definition: data_source.h:463
daal::data_management::interface1::NumericTableIface::minimum
Definition: numeric_table.h:296
daal::data_management::interface1::NumericTable::allocateBasicStatistics
virtual services::Status allocateBasicStatistics() DAAL_C11_OVERRIDE
daal::algorithms::low_order_moments::sumSquares
Definition: low_order_moments_types.h:90
daal::data_management::interface1::DataSource::checkNumericTable
services::Status checkNumericTable()
Definition: data_source.h:345
daal::algorithms::covariance::sum
Definition: covariance_types.h:78
daal::data_management::interface1::HomogenNumericTable::create
static services::SharedPtr< HomogenNumericTable< DataType > > create(NumericTableDictionaryPtr ddictForHomogenNumericTable, services::Status *stat=NULL)
Definition: homogen_numeric_table.h:93
daal::data_management::interface1::NumericTable
Class for a data management component responsible for representation of data in the numeric format...
Definition: numeric_table.h:575
daal::data_management::interface1::DataSourceIface::setDictionary
virtual services::Status setDictionary(DataSourceDictionary *dict)=0
daal::data_management::interface1::DataSource::loadDataBlock
size_t loadDataBlock() DAAL_C11_OVERRIDE
Definition: data_source.h:272
daal::data_management::interface1::NumericTableIface::doNotAllocate
Definition: numeric_table.h:285
daal::data_management::interface1::DataSourceTemplate::freeNumericTable
virtual void freeNumericTable() DAAL_C11_OVERRIDE
Definition: data_source.h:478
daal::data_management::interface1::NumericTable::resize
virtual services::Status resize(size_t nrows) DAAL_C11_OVERRIDE
Definition: numeric_table.h:637
daal::data_management::interface1::DataSource::getErrors
DAAL_DEPRECATED services::SharedPtr< services::ErrorCollection > getErrors()
Definition: data_source.h:322
daal::services::ErrorNumericTableAlreadyAllocated
Definition: error_indexes.h:155
daal::data_management::interface1::DataSourceIface::doDictionaryFromContext
Definition: data_source.h:72
daal::data_management::interface1::DataSourceIface::DataSourceStatus
DataSourceStatus
Specifies the status of the Data Source.
Definition: data_source.h:57
daal::data_management::interface1::NumericTableIface::maximum
Definition: numeric_table.h:297
daal::data_management::interface1::NumericTableIface::BasicStatisticsId
BasicStatisticsId
Enumeration to specify estimates of basic statistics stored.
Definition: numeric_table.h:294
daal::data_management::interface1::DataSourceIface::readyForLoad
Definition: data_source.h:59
daal::data_management::interface1::AOSNumericTable::create
static services::SharedPtr< AOSNumericTable > create(size_t structSize=0, size_t ncol=0, size_t nrow=0, services::Status *stat=NULL)
daal::data_management::interface1::DataSourceIface::getNumberOfColumns
virtual size_t getNumberOfColumns()=0
daal::data_management::interface1::DataSource::createDictionaryFromContext
services::Status createDictionaryFromContext() DAAL_C11_OVERRIDE
Definition: data_source.h:230
daal::services::ErrorDictionaryNotAvailable
Definition: error_indexes.h:153
daal::data_management::interface1::DataSourceIface::notDictionaryFromContext
Definition: data_source.h:71
daal::data_management::interface1::DataSourceIface::waitingForRows
Definition: data_source.h:60
daal::data_management::interface1::DataSource::loadDataBlock
size_t loadDataBlock(size_t maxRows, size_t rowOffset, size_t fullRows, NumericTable *nt) DAAL_C11_OVERRIDE
Definition: data_source.h:266
daal::data_management::interface1::DataSourceIface::getDictionary
virtual DAAL_DEPRECATED_VIRTUAL DataSourceDictionary * getDictionary()=0
daal::data_management::interface1::DataSourceIface::endOfData
Definition: data_source.h:61
daal::data_management::interface1::DataSource::getNumericTableNumberOfColumns
virtual size_t getNumericTableNumberOfColumns() DAAL_C11_OVERRIDE
Definition: data_source.h:327
daal::data_management::interface1::DataSourceIface::getDictionarySharedPtr
virtual DataSourceDictionaryPtr getDictionarySharedPtr()=0
daal::data_management::interface1::DataSourceIface::NumericTableAllocationFlag
NumericTableAllocationFlag
Specifies whether a Numeric Table is allocated inside of the Data Source object.
Definition: data_source.h:79
daal::data_management::interface1::DataSource::allocateNumericTableImpl
services::Status allocateNumericTableImpl(services::SharedPtr< NumericTableType > &nt)
Definition: data_source.h:421
daal::data_management::interface1::NumericTableIface::sum
Definition: numeric_table.h:298
daal::algorithms::implicit_als::training::offset
Definition: implicit_als_training_types.h:148
daal::data_management::interface1::DataSource::loadDataBlock
size_t loadDataBlock(size_t maxRows, NumericTable *nt) DAAL_C11_OVERRIDE
Definition: data_source.h:247
daal::data_management::interface1::DataSourceIface::getStatus
virtual DataSourceStatus getStatus()=0
daal::data_management::interface1::NumericTableIface::sumSquares
Definition: numeric_table.h:299
daal::data_management::interface1::DataSourceIface::getNumericTableNumberOfColumns
virtual size_t getNumericTableNumberOfColumns()=0
daal::services::ErrorNullNumericTable
Definition: error_indexes.h:113
daal::data_management::interface1::DataSource::setDictionary
services::Status setDictionary(DataSourceDictionary *dict) DAAL_C11_OVERRIDE
Definition: data_source.h:217
daal::data_management::interface1::DataSourceIface::notReady
Definition: data_source.h:62
daal::data_management::interface1::HomogenNumericTable
Class that provides methods to access data stored as a contiguous array of homogeneous feature vector...
Definition: homogen_numeric_table.h:52
daal::services::ErrorMethodNotSupported
Definition: error_indexes.h:69
daal::data_management::interface1::Dictionary
Class that represents a dictionary of a data set and provides methods to work with the data dictionar...
Definition: data_dictionary.h:161