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

Class DoubleCheckedDataReader

java.lang.Object

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

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

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

public class DoubleCheckedDataReader
extends ReductionCheckedDataReader<DoubleConsumer>

Field Summary

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

applier, inputStream

Constructor Summary

Constructors

Constructor and Description
DoubleCheckedDataReader(DataInput inputStream, DoubleConsumer applier)

Method Summary

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

Methods inherited from class org.apache.solr.analytics.stream.reservation.read.ReductionCheckedDataReader

read

Methods inherited from class java.lang.Object

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

Constructor Detail

DoubleCheckedDataReader

public DoubleCheckedDataReader(DataInput inputStream,
                               DoubleConsumer applier)

Method Detail

checkedRead

public void checkedRead()
                 throws IOException

Description copied from class: ReductionCheckedDataReader

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

Specified by:

checkedRead in class ReductionCheckedDataReader<DoubleConsumer>

Throws:

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