Class DoubleCheckedReservation
- java.lang.Object
-
- org.apache.solr.analytics.stream.reservation.ReductionDataReservation<A,E>
-
- org.apache.solr.analytics.stream.reservation.ReductionCheckedDataReservation<DoubleConsumer,DoubleSupplier>
-
- org.apache.solr.analytics.stream.reservation.DoubleCheckedReservation
-
public class DoubleCheckedReservation extends ReductionCheckedDataReservation<DoubleConsumer,DoubleSupplier>
-
-
Field Summary
-
Fields inherited from class org.apache.solr.analytics.stream.reservation.ReductionCheckedDataReservation
exists
-
Fields inherited from class org.apache.solr.analytics.stream.reservation.ReductionDataReservation
applier, extractor
-
-
Constructor Summary
Constructors Constructor Description DoubleCheckedReservation(DoubleConsumer applier, DoubleSupplier extractor, BooleanSupplier exists)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description DoubleCheckedDataReader
createReadStream(DataInput input)
Generate aReductionDataReader
that merges the set of data this reservation represents.DoubleCheckedDataWriter
createWriteStream(DataOutput output)
Generate aReductionDataWriter
that exports the set of data this reservation represents.
-
-
-
Constructor Detail
-
DoubleCheckedReservation
public DoubleCheckedReservation(DoubleConsumer applier, DoubleSupplier extractor, BooleanSupplier exists)
-
-
Method Detail
-
createReadStream
public DoubleCheckedDataReader 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 DoubleCheckedDataWriter 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
-
-