Class RowCollector<A>

  • All Implemented Interfaces:
    uk.ac.starlink.util.SplitCollector<RowSplittable,​A>

    public abstract class RowCollector<A>
    extends java.lang.Object
    implements uk.ac.starlink.util.SplitCollector<RowSplittable,​A>
    Convenience implementation of SplitCollector for use with table row processing.
    Since:
    5 Aug 2020
    Author:
    Mark Taylor
    • Constructor Detail

      • RowCollector

        public RowCollector()
    • Method Detail

      • accumulateRows

        public abstract void accumulateRows​(RowSplittable rseq,
                                            A acc)
                                     throws java.io.IOException
        Processes rows as required. This method is invoked by accumulate(uk.ac.starlink.table.RowSplittable, A), with the necessary IOException handling. Implementations do not need to close the supplied row sequence, which will be taken care of elsewhere.
        Parameters:
        rseq - row sequence
        acc - accumulator
        Throws:
        java.io.IOException
      • accumulate

        public final void accumulate​(RowSplittable rseq,
                                     A acc)
        Specified by:
        accumulate in interface uk.ac.starlink.util.SplitCollector<RowSplittable,​A>