public class BasicStreamingDataset extends AbstractDataset implements StreamingDatasetWriter
_columnNamesLowercase, columnNames, columnTypes, qualityCodes
Constructor and Description |
---|
BasicStreamingDataset() |
BasicStreamingDataset(java.util.List<java.lang.String> columnNames,
java.util.List<java.lang.Class<?>> columnTypes) |
BasicStreamingDataset(java.sql.ResultSet rs)
Creates a dataset by streaming the results of a JDBC ResultSet
|
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.
|
QualityCode[][] |
getBulkQualityCodes() |
java.lang.Exception |
getError() |
QualityCode |
getQualityAt(int row,
int col)
Returns the quality of the value at the given location.
|
int |
getRowCount()
Return the number of rows in this dataset
|
java.lang.Object |
getValueAt(int row,
int col)
Returns the value in the dataset at the given location.
|
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 |
printToConsole() |
void |
write(java.lang.Object[] data,
QualityCode[] quality)
Writes a row with the given data.
|
getAsXML, getColumnCount, getColumnIndex, getColumnName, getColumnNames, getColumnType, getColumnTypes, getPrimitiveValueAt, getValueAt, setColumnNames, setColumnTypes, setDirty
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
binarySearch, getColumnAsList
public BasicStreamingDataset()
public BasicStreamingDataset(java.util.List<java.lang.String> columnNames, java.util.List<java.lang.Class<?>> columnTypes)
public BasicStreamingDataset(java.sql.ResultSet rs) throws java.sql.SQLException
java.sql.SQLException
public java.lang.Exception getError()
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, QualityCode[] quality)
StreamingDatasetWriter
write
in interface StreamingDatasetWriter
public void finish()
StreamingDatasetWriter
finish
in interface StreamingDatasetWriter
public void finishWithError(java.lang.Exception e)
StreamingDatasetWriter
finishWithError
in interface StreamingDatasetWriter
public QualityCode getQualityAt(int row, int col)
Dataset
getQualityAt
in interface Dataset
getQualityAt
in class AbstractDataset
public int getRowCount()
Dataset
getRowCount
in interface Dataset
public java.lang.Object getValueAt(int row, int col)
Dataset
getValueAt
in interface Dataset
public void printToConsole()
public QualityCode[][] getBulkQualityCodes()
getBulkQualityCodes
in class AbstractDataset