Class ReductionDataReservation<A,​E>

    • Field Detail

      • applier

        protected final A applier
      • extractor

        protected final E extractor
    • Constructor Detail

      • ReductionDataReservation

        protected ReductionDataReservation​(A applier,
                                           E extractor)
    • Method Detail

      • createReadStream

        public abstract ReductionDataReader<A> createReadStream​(DataInput input)
        Generate a ReductionDataReader that merges the set of data this reservation represents.
        Parameters:
        input - the shard input stream
        Returns:
        a reader from the given input
      • createWriteStream

        public abstract ReductionDataWriter<E> createWriteStream​(DataOutput output)
        Generate a ReductionDataWriter that exports the set of data this reservation represents.
        Parameters:
        output - the shard output stream
        Returns:
        a writer to the given output