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 aDataOutputstream.
-
-
Field Summary
-
Fields inherited from class org.apache.solr.analytics.stream.reservation.write.ReductionDataWriter
extractor, output
-
-
Constructor Summary
Constructors Constructor Description ReductionDataArrayWriter(DataOutput output, C extractor, IntSupplier sizeSupplier)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description voidwrite()Write an array of data, retrieved from the extractor, and its size, received from the sizeSupplier, to the output stream.protected abstract voidwrite(int size)Write an array of data, retrieved from the extractor, with the given size to the output stream.
-
-
-
Constructor Detail
-
ReductionDataArrayWriter
public ReductionDataArrayWriter(DataOutput output, C extractor, IntSupplier sizeSupplier)
-
-
Method Detail
-
write
public void write() throws IOExceptionWrite an array of data, retrieved from the extractor, and its size, received from the sizeSupplier, to the output stream.- Specified by:
writein classReductionDataWriter<C>- Throws:
IOException- if an exception occurs while writing to the output stream
-
write
protected abstract void write(int size) throws IOExceptionWrite 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
-
-