T - the type of entity to writepublic class AvroPojoDatasetStoreReader<T> extends AbstractDatasetStoreReader<T,T>
DataStoreReader for reading Datasets using the Avro format.reader| Constructor and Description |
|---|
AvroPojoDatasetStoreReader(Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory,
DatasetDefinition datasetDefinition) |
| Modifier and Type | Method and Description |
|---|---|
protected T |
convertEntity(T entity)
Convert entity used by a reading into a entity
returned.
|
protected org.kitesdk.data.DatasetReader<T> |
createReader()
Creates a
DatasetReader. |
close, getDatasetDefinition, getDatasetRepositoryFactory, getEntityClass, readpublic AvroPojoDatasetStoreReader(Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory, DatasetDefinition datasetDefinition)
protected T convertEntity(T entity)
AbstractDatasetStoreReaderconvertEntity in class AbstractDatasetStoreReader<T,T>entity - the entityprotected org.kitesdk.data.DatasetReader<T> createReader()
AbstractDatasetStoreReaderDatasetReader.createReader in class AbstractDatasetStoreReader<T,T>