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(java.lang.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, read
public AvroPojoDatasetStoreReader(java.lang.Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory, DatasetDefinition datasetDefinition)
protected T convertEntity(T entity)
AbstractDatasetStoreReader
convertEntity
in class AbstractDatasetStoreReader<T,T>
entity
- the entityprotected org.kitesdk.data.DatasetReader<T> createReader()
AbstractDatasetStoreReader
DatasetReader
.createReader
in class AbstractDatasetStoreReader<T,T>