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 aReductionDataCollectorto specify a piece of data it needs to export from the shard.
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedReductionDataReservation(A applier, E extractor)
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract ReductionDataReader<A>createReadStream(DataInput input)Generate aReductionDataReaderthat merges the set of data this reservation represents.abstract ReductionDataWriter<E>createWriteStream(DataOutput output)Generate aReductionDataWriterthat exports the set of data this reservation represents.
-
-
-
Method Detail
-
createReadStream
public abstract ReductionDataReader<A> createReadStream(DataInput input)
Generate aReductionDataReaderthat 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 aReductionDataWriterthat exports the set of data this reservation represents.- Parameters:
output- the shard output stream- Returns:
- a writer to the given output
-
-