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

Class ReductionCheckedDataReader<A>

java.lang.Object

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

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

Direct Known Subclasses:

BooleanCheckedDataReader, DoubleCheckedDataReader, FloatCheckedDataReader, IntCheckedDataReader, LongCheckedDataReader, StringCheckedDataReader

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

Abstract class to manage the reading and application of data from a DataInput stream. The data being read may not exist, so the reader first checks before reading.

Field Summary

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

applier, inputStream

Constructor Summary

Constructors

Constructor and Description
ReductionCheckedDataReader(DataInput inputStream, A applier)

Method Summary

Modifier and Type	Method and Description
protected abstract void	checkedRead() Read a piece of data from the input stream and feed it to the applier.
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

Constructor Detail

ReductionCheckedDataReader

public ReductionCheckedDataReader(DataInput inputStream,
                                  A applier)

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 class ReductionDataReader<A>

Throws:

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

checkedRead

protected abstract void checkedRead()
                             throws IOException

Read a piece of data from the input stream and feed it to the applier.
This piece of data is guaranteed to be there.

Throws:

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