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