Package org.apache.solr.analytics.stream.reservation

Class BooleanArrayReservation

java.lang.Object

org.apache.solr.analytics.stream.reservation.ReductionDataReservation<A,E>

org.apache.solr.analytics.stream.reservation.ReductionDataArrayReservation<BooleanConsumer,BooleanSupplier>

org.apache.solr.analytics.stream.reservation.BooleanArrayReservation

public class BooleanArrayReservation
extends ReductionDataArrayReservation<BooleanConsumer,BooleanSupplier>

Field Summary

Fields inherited from class org.apache.solr.analytics.stream.reservation.ReductionDataArrayReservation

sizeApplier, sizeExtractor

Fields inherited from class org.apache.solr.analytics.stream.reservation.ReductionDataReservation

applier, extractor

Constructor Summary

Constructors

Constructor	Description
BooleanArrayReservation(BooleanConsumer applier, IntConsumer sizeApplier, BooleanSupplier extractor, IntSupplier sizeExtractor)

Method Summary

Modifier and Type	Method	Description
BooleanDataArrayReader	createReadStream(DataInput input)	Generate a ReductionDataReader that merges the set of data this reservation represents.
BooleanDataArrayWriter	createWriteStream(DataOutput output)	Generate a ReductionDataWriter that exports the set of data this reservation represents.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BooleanArrayReservation

public BooleanArrayReservation(BooleanConsumer applier,
                               IntConsumer sizeApplier,
                               BooleanSupplier extractor,
                               IntSupplier sizeExtractor)

Method Detail

createReadStream

public BooleanDataArrayReader createReadStream(DataInput input)

Description copied from class: ReductionDataReservation

Generate a ReductionDataReader that merges the set of data this reservation represents.

Specified by:

createReadStream in class ReductionDataReservation<BooleanConsumer,BooleanSupplier>

Parameters:

input - the shard input stream

Returns:

a reader from the given input

createWriteStream

public BooleanDataArrayWriter createWriteStream(DataOutput output)

Description copied from class: ReductionDataReservation

Generate a ReductionDataWriter that exports the set of data this reservation represents.

Specified by:

createWriteStream in class ReductionDataReservation<BooleanConsumer,BooleanSupplier>

Parameters:

output - the shard output stream

Returns:

a writer to the given output