public interface StreamingDatasetWriter
Modifier and Type | Method and Description |
---|---|
void |
finish()
Notifies the writer to close- all data has been written.
|
void |
finishWithError(java.lang.Exception e)
Finishes the stream while indicating an error occurred.
|
void |
initialize(java.lang.String[] columnNames,
java.lang.Class<?>[] columnTypes,
boolean supportsQuality,
int expectedRows)
Initializes the streaming dataset with important information, primarily the column names and types.
|
void |
write(java.lang.Object[] data,
DataQuality[] quality)
Writes a row with the given data.
|
void initialize(java.lang.String[] columnNames, java.lang.Class<?>[] columnTypes, boolean supportsQuality, int expectedRows)
expectedRows
- -1 if not known, otherwise the number of rows that will be in the dataset.void write(java.lang.Object[] data, DataQuality[] quality) throws java.io.IOException
java.io.IOException
void finish()
void finishWithError(java.lang.Exception e)