Class FloatCheckedReservation
- java.lang.Object
-
- org.apache.solr.analytics.stream.reservation.ReductionDataReservation<A,E>
-
- org.apache.solr.analytics.stream.reservation.ReductionCheckedDataReservation<FloatConsumer,FloatSupplier>
-
- org.apache.solr.analytics.stream.reservation.FloatCheckedReservation
-
public class FloatCheckedReservation extends ReductionCheckedDataReservation<FloatConsumer,FloatSupplier>
-
-
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 FloatCheckedReservation(FloatConsumer applier, FloatSupplier extractor, BooleanSupplier exists)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FloatCheckedDataReader
createReadStream(DataInput input)
Generate aReductionDataReader
that merges the set of data this reservation represents.FloatCheckedDataWriter
createWriteStream(DataOutput output)
Generate aReductionDataWriter
that exports the set of data this reservation represents.
-
-
-
Constructor Detail
-
FloatCheckedReservation
public FloatCheckedReservation(FloatConsumer applier, FloatSupplier extractor, BooleanSupplier exists)
-
-
Method Detail
-
createReadStream
public FloatCheckedDataReader createReadStream(DataInput input)
Description copied from class:ReductionDataReservation
Generate aReductionDataReader
that merges the set of data this reservation represents.- Specified by:
createReadStream
in classReductionDataReservation<FloatConsumer,FloatSupplier>
- Parameters:
input
- the shard input stream- Returns:
- a reader from the given input
-
createWriteStream
public FloatCheckedDataWriter createWriteStream(DataOutput output)
Description copied from class:ReductionDataReservation
Generate aReductionDataWriter
that exports the set of data this reservation represents.- Specified by:
createWriteStream
in classReductionDataReservation<FloatConsumer,FloatSupplier>
- Parameters:
output
- the shard output stream- Returns:
- a writer to the given output
-
-