public class AvroPojoDatasetStoreWriter<T> extends AbstractDatasetStoreWriter<T>
DataStoreWriter for writing Datasets using the Avro format.| Modifier and Type | Field and Description |
|---|---|
protected org.kitesdk.data.DatasetWriter<T> |
writer |
datasetDefinition, datasetRepositoryFactory, entityClass| Constructor and Description |
|---|
AvroPojoDatasetStoreWriter(Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory)
Instantiates a new
DataStoreWriter for writing Avro records to a org.kitesdk.data.Dataset. |
AvroPojoDatasetStoreWriter(Class<T> entityClass,
DatasetRepositoryFactory datasetRepositoryFactory,
DatasetDefinition datasetDefinition)
Instantiates a new
DataStoreWriter for writing Avro records to a org.kitesdk.data.Dataset. |
protected volatile org.kitesdk.data.DatasetWriter<T> writer
public AvroPojoDatasetStoreWriter(Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory)
DataStoreWriter for writing Avro 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 AvroPojoDatasetStoreWriter(Class<T> entityClass, DatasetRepositoryFactory datasetRepositoryFactory, DatasetDefinition datasetDefinition)
DataStoreWriter for writing Avro 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