org.apache.solr.analytics.stream.reservation.write

Class ReductionDataArrayWriter<C>

java.lang.Object

org.apache.solr.analytics.stream.reservation.write.ReductionDataWriter<C>

org.apache.solr.analytics.stream.reservation.write.ReductionDataArrayWriter<C>

Direct Known Subclasses:

BooleanDataArrayWriter, DoubleDataArrayWriter, FloatDataArrayWriter, IntDataArrayWriter, LongDataArrayWriter, StringDataArrayWriter

public abstract class ReductionDataArrayWriter<C>
extends ReductionDataWriter<C>

Abstract class to manage the extraction and writing of array data to a DataOutput stream.

Field Summary

Fields inherited from class org.apache.solr.analytics.stream.reservation.write.ReductionDataWriter

extractor, output

Constructor Summary

Constructors

Constructor and Description
ReductionDataArrayWriter(DataOutput output, C extractor, IntSupplier sizeSupplier)

Method Summary

Modifier and Type	Method and Description
void	write() Write an array of data, retrieved from the extractor, and its size, received from the sizeSupplier, to the output stream.
protected abstract void	write(int size) Write an array of data, retrieved from the extractor, with the given size to the output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReductionDataArrayWriter

public ReductionDataArrayWriter(DataOutput output,
                                C extractor,
                                IntSupplier sizeSupplier)

Method Detail

write

public void write()
           throws IOException

Write an array of data, retrieved from the extractor, and its size, received from the sizeSupplier, to the output stream.

Specified by:

write in class ReductionDataWriter<C>

Throws:

IOException - if an exception occurs while writing to the output stream

write

protected abstract void write(int size)
                       throws IOException

Write an array of data, retrieved from the extractor, with the given size to the output stream.

Throws:

IOException - if an exception occurs while writing to the output stream