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

Class ReductionDataReader<A>

java.lang.Object

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

Direct Known Subclasses:

BooleanDataReader, DoubleDataReader, FloatDataReader, IntDataReader, LongDataReader, ReductionCheckedDataReader, ReductionDataArrayReader, StringDataReader

public abstract class ReductionDataReader<A>
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
protected A	applier
protected DataInput	inputStream

Constructor Summary

Constructors

Constructor and Description
ReductionDataReader(DataInput inputStream, A applier)

Method Summary

Modifier and Type	Method and Description
abstract void	read() Read a piece of data from the input stream and feed it to the applier.

Methods inherited from class java.lang.Object

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

Field Detail

inputStream

protected final DataInput inputStream

applier

protected final A applier

Constructor Detail

ReductionDataReader

public ReductionDataReader(DataInput inputStream,
                           A applier)

Method Detail

read

public abstract void read()
                   throws IOException

Read a piece of data from the input stream and feed it to the applier.

Throws:

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