public class LimitRowSink
extends java.lang.Object
implements uk.ac.starlink.table.TableSink
Constructor and Description |
---|
LimitRowSink(uk.ac.starlink.table.TableSink base,
long maxrow)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
acceptMetadata(uk.ac.starlink.table.StarTable table) |
void |
acceptRow(java.lang.Object[] row) |
void |
endRows() |
boolean |
isTruncated()
Indicates whether this sink has received any rows that it has
refused to pass on to its base sink.
|
public LimitRowSink(uk.ac.starlink.table.TableSink base, long maxrow)
base
- base sinkmaxrow
- maximum number of rows this sink will transmit
to its basepublic void acceptMetadata(uk.ac.starlink.table.StarTable table) throws uk.ac.starlink.table.TableFormatException
acceptMetadata
in interface uk.ac.starlink.table.TableSink
uk.ac.starlink.table.TableFormatException
public void acceptRow(java.lang.Object[] row) throws java.io.IOException
acceptRow
in interface uk.ac.starlink.table.TableSink
java.io.IOException
public void endRows() throws java.io.IOException
endRows
in interface uk.ac.starlink.table.TableSink
java.io.IOException
public boolean isTruncated()
Copyright © 2017 Central Laboratory of the Research Councils. All Rights Reserved.