Package com.streambase.sb.operator
Interface RowConsumer
-
public interface RowConsumer
Interface for consumers of table rows.- Since:
- 7.2
- See Also:
PreparedQuery
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
consume(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
-
-