Class DoubleArrayReservation
- java.lang.Object
-
- org.apache.solr.analytics.stream.reservation.ReductionDataReservation<A,E>
-
- org.apache.solr.analytics.stream.reservation.ReductionDataArrayReservation<DoubleConsumer,DoubleSupplier>
-
- org.apache.solr.analytics.stream.reservation.DoubleArrayReservation
-
public class DoubleArrayReservation extends ReductionDataArrayReservation<DoubleConsumer,DoubleSupplier>
-
-
Field Summary
-
Fields inherited from class org.apache.solr.analytics.stream.reservation.ReductionDataArrayReservation
sizeApplier, sizeExtractor
-
Fields inherited from class org.apache.solr.analytics.stream.reservation.ReductionDataReservation
applier, extractor
-
-
Constructor Summary
Constructors Constructor Description DoubleArrayReservation(DoubleConsumer applier, IntConsumer sizeApplier, DoubleSupplier extractor, IntSupplier sizeExtractor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DoubleDataArrayReader
createReadStream(DataInput input)
Generate aReductionDataReader
that merges the set of data this reservation represents.DoubleDataArrayWriter
createWriteStream(DataOutput output)
Generate aReductionDataWriter
that exports the set of data this reservation represents.
-
-
-
Constructor Detail
-
DoubleArrayReservation
public DoubleArrayReservation(DoubleConsumer applier, IntConsumer sizeApplier, DoubleSupplier extractor, IntSupplier sizeExtractor)
-
-
Method Detail
-
createReadStream
public DoubleDataArrayReader createReadStream(DataInput input)
Description copied from class:ReductionDataReservation
Generate aReductionDataReader
that merges the set of data this reservation represents.- Specified by:
createReadStream
in classReductionDataReservation<DoubleConsumer,DoubleSupplier>
- Parameters:
input
- the shard input stream- Returns:
- a reader from the given input
-
createWriteStream
public DoubleDataArrayWriter createWriteStream(DataOutput output)
Description copied from class:ReductionDataReservation
Generate aReductionDataWriter
that exports the set of data this reservation represents.- Specified by:
createWriteStream
in classReductionDataReservation<DoubleConsumer,DoubleSupplier>
- Parameters:
output
- the shard output stream- Returns:
- a writer to the given output
-
-