|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface RowPipe
TableSink implementation whose returned table reads concurrently from rows written into it. Some of the methods may block, and the reading and writing have to be done in different threads.
This serves almost the same purpose as a
RowStore
, but has a subtly different contract.
Instead of RowStore's RowStore.getStarTable()
method, which must be called after the endRows
method,
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.
Method Summary | |
---|---|
void |
setError(IOException e)
May be called by the writing stream to set an I/O error on the pipe. |
StarTable |
waitForStarTable()
Returns a table whose data is supplied by that written into this sink. |
Methods inherited from interface uk.ac.starlink.table.TableSink |
---|
acceptMetadata, acceptRow, endRows |
Method Detail |
---|
StarTable waitForStarTable() throws IOException
TableSink.acceptMetadata(uk.ac.starlink.table.StarTable)
has been called.
IOException
void setError(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
|
Copyright © 2004 CLRC: Central Laboratory of the Research Councils. All rights reserved. | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |