Class ChangelogReaderWrapper

  • All Implemented Interfaces:
    ChangelogReaderIF, TupleReaderIF

    public class ChangelogReaderWrapper
    extends Object
    implements ChangelogReaderIF
    INTERNAL: This tuple reader wraps an underlying tuple reader, and collapses a sequence of actions for the same key into a single final action. Tuples are coming through ordered by key first, then by sequence.
    • Method Detail

      • getOrderValue

        public String getOrderValue()
        Description copied from interface: ChangelogReaderIF
        INTERNAL: Returns the current order value found in the order-column. This information is used so that one can keep track of incremental updates.
        Specified by:
        getOrderValue in interface ChangelogReaderIF
      • readNext

        public String[] readNext()
        Description copied from interface: TupleReaderIF
        INTERNAL: Returns the next tuple. Method will return null when there are no more tuples.
        Specified by:
        readNext in interface TupleReaderIF
      • close

        public void close()
        Description copied from interface: TupleReaderIF
        INTERNAL: Releases all resources held by the tuple reader. This method should be called when done with the tuple reader.
        Specified by:
        close in interface TupleReaderIF