Package com.streambase.sb.operator

Interface RowConsumer

public interface RowConsumer
Interface for consumers of table rows.
Since:
7.2
See Also:

  • 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