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 aDataInput
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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
read()
Read a piece of data from the input stream and feed it to the applier.protected abstract void
read(int size)
Read an array from the input stream, feeding each member to the applier.
-
-
-
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
Description copied from class:ReductionDataReader
Read a piece of data from the input stream and feed it to the applier.- Specified by:
read
in classReductionDataReader<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
-
-