Package com.illumon.iris.binarystore

Class AbstractBinaryStoreWriter<R extends Row>

java.lang.Object

com.illumon.iris.binarystore.AbstractBinaryStoreWriter<R>

All Implemented Interfaces:

Entry, Record, Row, TableWriter<R>

Direct Known Subclasses:

BinaryStoreWriterV2

public abstract class AbstractBinaryStoreWriter<R extends Row>
extends Object
implements TableWriter<R>

This class provides a common ancestor for V1 and V2 binary store writer to manage output channels. The extending class is responsible for creating a ByteBuffer that represents the header, and actually writing data to the file channel using the writeDataBuffer call.

Nested Class Summary

Nested classes/interfaces inherited from interface com.illumon.iris.binarystore.Record

Record.RecordSetter<T extends RecordData>

Nested classes/interfaces inherited from interface com.illumon.iris.binarystore.Row

Row.Flags

Field Summary

Fields inherited from interface com.illumon.iris.binarystore.TableWriter

NULL_SETTER

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the writer.
void	flush()	Flushes data out.
protected void	setChannelManager(ChannelManager channelManager)
boolean	supportAllTypes()	True if all data types can be written out; false otherwise.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.binarystore.Row

getColumnPartitionValue, setColumnPartitionValue

Methods inherited from interface com.illumon.iris.binarystore.TableWriter

flushDeferredRows, getColumnNames, getColumnTypes, getRecordSetter, getRecordSetter, getRecordWriter, getRowWriter, getSetter, getSetter, setFlags, writeDeferredRow, writeRecord, writeRow

Method Details

setChannelManager

protected void setChannelManager(@NotNull ChannelManager channelManager)

close

public void close() throws IOException

Description copied from interface: TableWriter

Closes the writer.

Specified by:

close in interface TableWriter<R extends Row>

Throws:

IOException - problem closing the writer.

flush

public void flush() throws IOException

Description copied from interface: TableWriter

Flushes data out.

Specified by:

flush in interface TableWriter<R extends Row>

Throws:

IOException - problem flushing data out.

supportAllTypes

public boolean supportAllTypes()

Description copied from interface: TableWriter

True if all data types can be written out; false otherwise.

Specified by:

supportAllTypes in interface TableWriter<R extends Row>

Returns:

true if all data types can be written out; false otherwise.