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

Class ReductionCheckedDataWriter<C>

java.lang.Object

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

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

Direct Known Subclasses:

BooleanCheckedDataWriter, DoubleCheckedDataWriter, FloatCheckedDataWriter, IntCheckedDataWriter, LongCheckedDataWriter, StringCheckedDataWriter

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

Abstract class to manage the extraction and writing of data to a DataOutput stream. The data being written may not exist, so the writer first writes whether the data exists before writing the data.

Field Summary

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

extractor, output

Constructor Summary

Constructors

Constructor	Description
ReductionCheckedDataWriter(DataOutput output, C extractor, BooleanSupplier existsSupplier)

Method Summary

Modifier and Type	Method	Description
protected abstract void	checkedWrite()	Write a piece of data, retrieved from the extractor, to the output stream.
void	write()	Write a piece of data, retrieved from the extractor, to the output stream.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReductionCheckedDataWriter

public ReductionCheckedDataWriter(DataOutput output,
                                  C extractor,
                                  BooleanSupplier existsSupplier)

Method Detail

write

public void write()
           throws IOException

Write a piece of data, retrieved from the extractor, to the output stream.
First writes whether the data exists, then if it does exists writes the data.

Specified by:

write in class ReductionDataWriter<C>

Throws:

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

checkedWrite

protected abstract void checkedWrite()
                              throws IOException

Write a piece of data, retrieved from the extractor, to the output stream.
The data being written is guaranteed to exist.

Throws:

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