public interface RowConsumerInterface for consumers of table rows.
- See Also:
void consume(Tuple row) throws StreamBaseExceptionOverride this method to consume rows. The row should be fully consumed and not aliased when the method returns. A thrown StreamBase exception will terminate further processing in the executing query.
row- tuple to consume
StreamBaseException- when thrown, aborts the current query