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 aDataOutput
stream.
-
-
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 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.
-
-
-
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 classReductionDataWriter<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
-
-