Package com.streambase.sb.operator

Interface RowConsumer

public interface RowConsumer

Interface for consumers of table rows.

Since:

7.2

See Also:

• PreparedQuery

Method Summary

Modifier and Type	Method	Description
void	consume(Tuple row)	Override this method to consume rows.

Method Details

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