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)
e as 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