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

Class StringCheckedDataReader

java.lang.Object

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

org.apache.solr.analytics.stream.reservation.read.ReductionCheckedDataReader<Consumer<String>>

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

public class StringCheckedDataReader
extends ReductionCheckedDataReader<Consumer<String>>

Field Summary

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

applier, inputStream

Constructor Summary

Constructors

Constructor and Description
StringCheckedDataReader(DataInput inputStream, Consumer<String> 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

StringCheckedDataReader

public StringCheckedDataReader(DataInput inputStream,
                               Consumer<String> 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<Consumer<String>>

Throws:

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