Class ReductionDataReservation<A,E>
- java.lang.Object
-
- org.apache.solr.analytics.stream.reservation.ReductionDataReservation<A,E>
-
- Direct Known Subclasses:
BooleanReservation
,DoubleReservation
,FloatReservation
,IntReservation
,LongReservation
,ReductionCheckedDataReservation
,ReductionDataArrayReservation
,StringReservation
public abstract class ReductionDataReservation<A,E> extends Object
A reservation allows aReductionDataCollector
to specify a piece of data it needs to export from the shard.
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
ReductionDataReservation(A applier, E extractor)
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract ReductionDataReader<A>
createReadStream(DataInput input)
Generate aReductionDataReader
that merges the set of data this reservation represents.abstract ReductionDataWriter<E>
createWriteStream(DataOutput output)
Generate aReductionDataWriter
that exports the set of data this reservation represents.
-
-
-
Method Detail
-
createReadStream
public abstract ReductionDataReader<A> createReadStream(DataInput input)
Generate aReductionDataReader
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 aReductionDataWriter
that exports the set of data this reservation represents.- Parameters:
output
- the shard output stream- Returns:
- a writer to the given output
-
-