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(java.lang.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, read
public ParquetDatasetStoreReader(java.lang.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()
AbstractDatasetStoreReader
DatasetReader
.createReader
in class AbstractDatasetStoreReader<T,org.apache.avro.generic.GenericRecord>
protected T convertEntity(org.apache.avro.generic.GenericRecord entity)
AbstractDatasetStoreReader
convertEntity
in class AbstractDatasetStoreReader<T,org.apache.avro.generic.GenericRecord>
entity
- the entity