public interface RowConsumer
PreparedQuery
Modifier and Type | Method and Description |
---|---|
void |
consume(Tuple row)
Override this method to consume rows.
|
void consume(Tuple row) throws StreamBaseException
row
- tuple to consumeStreamBaseException
- when thrown, aborts the current query