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(Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory)
Instantiates a new
DataStoreWriter for writing Parquet records to a org.kitesdk.data.Dataset. |
ParquetDatasetStoreWriter(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(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(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 IOException
DataWriterIOException - if an I/O error occurspublic void flush()
throws IOException
IOExceptionpublic void close()
throws IOException
IOException