public class FilteredStreamingDatasetWriter extends java.lang.Object implements StreamingDatasetWriter
Constructor and Description |
---|
FilteredStreamingDatasetWriter(StreamingDatasetWriter core,
java.lang.Integer[] filteredColumnIndexes) |
FilteredStreamingDatasetWriter(StreamingDatasetWriter core,
java.lang.String[] filteredColumnNames) |
Modifier and Type | Method and Description |
---|---|
protected <T> T[] |
filterArray(T[] arry) |
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.
|
protected void |
initializeIndexesForNames(java.lang.String[] names) |
void |
write(java.lang.Object[] data,
DataQuality[] quality)
Writes a row with the given data.
|
public FilteredStreamingDatasetWriter(StreamingDatasetWriter core, java.lang.Integer[] filteredColumnIndexes)
public FilteredStreamingDatasetWriter(StreamingDatasetWriter core, java.lang.String[] filteredColumnNames)
protected void initializeIndexesForNames(java.lang.String[] names)
protected <T> T[] filterArray(T[] arry)
public void initialize(java.lang.String[] columnNames, java.lang.Class<?>[] columnTypes, boolean supportsQuality, int expectedRows)
StreamingDatasetWriter
initialize
in interface StreamingDatasetWriter
expectedRows
- -1 if not known, otherwise the number of rows that will be in the dataset.public void write(java.lang.Object[] data, DataQuality[] quality) throws java.io.IOException
StreamingDatasetWriter
write
in interface StreamingDatasetWriter
java.io.IOException
public void finish()
StreamingDatasetWriter
finish
in interface StreamingDatasetWriter
public void finishWithError(java.lang.Exception e)
StreamingDatasetWriter
finishWithError
in interface StreamingDatasetWriter