public class ParquetDatasetStoreWriter<T> extends AbstractDatasetStoreWriter<T>
DataStoreWriter
for writing Datasets using the Parquet format.Modifier and Type | Field and Description |
---|---|
protected org.apache.avro.Schema |
schema |
protected org.kitesdk.data.DatasetWriter<org.apache.avro.generic.GenericRecord> |
writer |
datasetDefinition, datasetRepositoryFactory, entityClass
Constructor and Description |
---|
ParquetDatasetStoreWriter(java.lang.Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory)
Instantiates a new
DataStoreWriter for writing Parquet records to a org.kitesdk.data.Dataset . |
ParquetDatasetStoreWriter(java.lang.Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory,
DatasetDefinition datasetDefinition)
Instantiates a new
DataStoreWriter for writing Parquet records to a org.kitesdk.data.Dataset . |
protected volatile org.kitesdk.data.DatasetWriter<org.apache.avro.generic.GenericRecord> writer
protected volatile org.apache.avro.Schema schema
public ParquetDatasetStoreWriter(java.lang.Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory)
DataStoreWriter
for writing Parquet records to a org.kitesdk.data.Dataset
.entityClass
- the Class
that the writer will write to the DatasetdatasetRepositoryFactory
- the DatasetRepositoryFactory
to be used for the writerpublic ParquetDatasetStoreWriter(java.lang.Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory, DatasetDefinition datasetDefinition)
DataStoreWriter
for writing Parquet records to a org.kitesdk.data.Dataset
.entityClass
- the Class
that the writer will write to the DatasetdatasetRepositoryFactory
- the DatasetRepositoryFactory
to be used for the writerdatasetDefinition
- the DatasetDefinition
to be used for the writerpublic void write(T entity) throws java.io.IOException
DataWriter
java.io.IOException
- if an I/O error occurspublic void flush() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException