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

Class StringDataArrayReader

java.lang.Object

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

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

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

public class StringDataArrayReader
extends ReductionDataArrayReader<Consumer<String>>

Field Summary

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

signal

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

applier, inputStream

Constructor Summary

Constructors

Constructor	Description
StringDataArrayReader(DataInput inputStream, Consumer<String> applier, IntConsumer signal)

Method Summary

Modifier and Type	Method	Description
void	read(int size)	Read an array from the input stream, feeding each member to the applier.

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

read

Methods inherited from class java.lang.Object

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

Constructor Detail

StringDataArrayReader

public StringDataArrayReader(DataInput inputStream,
                             Consumer<String> applier,
                             IntConsumer signal)

Method Detail

read

public void read(int size)
          throws IOException

Description copied from class: ReductionDataArrayReader

Read an array from the input stream, feeding each member to the applier.

Specified by:

read in class ReductionDataArrayReader<Consumer<String>>

Parameters:

size - length of the array to read

Throws:

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