Package com.streambase.sb.operator
Interface RowConsumer
-
public interface RowConsumerInterface for consumers of table rows.- Since:
- 7.2
- See Also:
PreparedQuery
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidconsume(Tuple row)Override this method to consume rows.
-
-
-
Method Detail
-
consume
void consume(Tuple row) throws StreamBaseException
Override 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.- Parameters:
row- tuple to consume- Throws:
StreamBaseException- when thrown, aborts the current query
-
-