org.apache.solr.analytics.stream.reservation

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 a ReductionDataCollector to specify a piece of data it needs to export from the shard.

Field Summary

Fields

Modifier and Type	Field and Description
protected A	applier
protected E	extractor

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ReductionDataReservation(A applier, E extractor)

Method Summary

Modifier and Type	Method and Description
abstract ReductionDataReader<A>	createReadStream(DataInput input) Generate a ReductionDataReader that merges the set of data this reservation represents.
abstract ReductionDataWriter<E>	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

Field Detail

applier

protected final A applier

extractor

protected final E extractor

Constructor Detail

ReductionDataReservation

protected ReductionDataReservation(A applier,
                                   E extractor)

Method Detail

createReadStream

public abstract ReductionDataReader<A> createReadStream(DataInput input)

Generate a ReductionDataReader 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 a ReductionDataWriter that exports the set of data this reservation represents.

Parameters:

output - the shard output stream

Returns:

a writer to the given output