Interface RowConsumer


  • public interface RowConsumer
    Interface for consumers of table rows.
    Since:
    7.2
    See Also:
    PreparedQuery
    • 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