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

Class ReductionDataArrayReader<A>

java.lang.Object

org.apache.solr.analytics.stream.reservation.read.ReductionDataReader<A>

org.apache.solr.analytics.stream.reservation.read.ReductionDataArrayReader<A>

Direct Known Subclasses:

BooleanDataArrayReader, DoubleDataArrayReader, FloatDataArrayReader, IntDataArrayReader, LongDataArrayReader, StringDataArrayReader

public abstract class ReductionDataArrayReader<A>
extends ReductionDataReader<A>

Abstract class to manage the reading and application of array data from a DataInput stream.

Field Summary

Fields

Modifier and Type	Field	Description
protected IntConsumer	signal

Fields inherited from class org.apache.solr.analytics.stream.reservation.read.ReductionDataReader

applier, inputStream

Constructor Summary

Constructors

Constructor	Description
ReductionDataArrayReader(DataInput inputStream, A applier, IntConsumer signal)

Method Summary

Modifier and Type	Method	Description
void	read()	Read an array of data from the input stream and feed it to the applier, first signaling the size of the array.
protected abstract void	read(int size)	Read an array from the input stream, feeding each member to the applier.

Methods inherited from class java.lang.Object

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

Field Detail

signal

protected final IntConsumer signal

Constructor Detail

ReductionDataArrayReader

public ReductionDataArrayReader(DataInput inputStream,
                                A applier,
                                IntConsumer signal)

Method Detail

read

public void read()
          throws IOException

Read an array of data from the input stream and feed it to the applier, first signaling the size of the array.

Specified by:

read in class ReductionDataReader<A>

Throws:

IOException - if an exception occurs while reading from the input stream

read

protected abstract void read(int size)
                      throws IOException

Read an array from the input stream, feeding each member to the applier.

Parameters:

size - length of the array to read

Throws:

IOException - if an exception occurs while reading from the input stream