public interface RowPipe extends TableSink
This serves almost the same purpose as a
RowStore, but has a subtly different contract.
Instead of RowStore's
method, which must be called after the
it provides a
waitForStarTable() method which may be called
before any or all rows have been written, but on a different thread.
This blocks until the metadata has been supplied.
|Modifier and Type||Method and Description|
May be called by the writing stream to set an I/O error on the pipe.
Returns a table whose data is supplied by that written into this sink.
StarTable waitForStarTable() throws java.io.IOException
TableSink.acceptMetadata(uk.ac.starlink.table.StarTable)has been called.
void setError(java.io.IOException e)
eas its cause from one of the read methods. If an error has already been set by a previous call of this method, this has no effect (only the first error is set).
e- exception to pass to readers