Class ReductionDataReader<A>

    • Field Detail

      • inputStream

        protected final DataInput inputStream
      • applier

        protected final A applier
    • Constructor Detail

      • ReductionDataReader

        public ReductionDataReader​(DataInput inputStream,
                                   A applier)
    • Method Detail

      • read

        public abstract void read()
                           throws IOException
        Read a piece of data from the input stream and feed it to the applier.
        Throws:
        IOException - if an exception occurs while reading from the input stream