T - the type of entity to readpublic class ParquetDatasetStoreReader<T> extends AbstractDatasetStoreReader<T,org.apache.avro.generic.GenericRecord>
DataStoreReader for reading Datasets using the Parquet format.| Modifier and Type | Field and Description |
|---|---|
protected org.apache.avro.Schema |
schema |
reader| Constructor and Description |
|---|
ParquetDatasetStoreReader(Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory,
DatasetDefinition datasetDefinition)
Instantiates a new parquet dataset store reader.
|
| Modifier and Type | Method and Description |
|---|---|
protected T |
convertEntity(org.apache.avro.generic.GenericRecord entity)
Convert entity used by a reading into a entity
returned.
|
protected org.kitesdk.data.DatasetReader<org.apache.avro.generic.GenericRecord> |
createReader()
Creates a
DatasetReader. |
close, getDatasetDefinition, getDatasetRepositoryFactory, getEntityClass, readpublic ParquetDatasetStoreReader(Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory, DatasetDefinition datasetDefinition)
entityClass - the entity classdatasetRepositoryFactory - the dataset repository factorydatasetDefinition - the dataset definitionprotected org.kitesdk.data.DatasetReader<org.apache.avro.generic.GenericRecord> createReader()
AbstractDatasetStoreReaderDatasetReader.createReader in class AbstractDatasetStoreReader<T,org.apache.avro.generic.GenericRecord>protected T convertEntity(org.apache.avro.generic.GenericRecord entity)
AbstractDatasetStoreReaderconvertEntity in class AbstractDatasetStoreReader<T,org.apache.avro.generic.GenericRecord>entity - the entity