Package com.illumon.iris.db.tables.dataimport

Class StreamTableWriter

java.lang.Object

com.illumon.iris.db.tables.dataimport.StreamTableWriter

All Implemented Interfaces:

Entry, Record, Row, TableWriter

public class StreamTableWriter
extends Object
implements TableWriter

A "stream" table writer that outputs to a single byte buffer sink.

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

Constructor Summary

Constructors

Constructor	Description
StreamTableWriter(TableDefinition definition, com.fishlib.io.streams.CurrentByteBufferSink byteBufferSink)	Create a stream table writer that writes to the supplied sink.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the writer.
void	flush()	Flushes data out.
String[]	getColumnNames()	Gets the column names for the table.
Class[]	getColumnTypes()	Gets the column types for the table.
Row	getRowWriter()	Get a writer for a Row entries.
RowSetter	getSetter(String name)	Gets a setter for a column.
void	setFlags(Row.Flags flags)
boolean	supportAllTypes()	True if all data types can be written out; false otherwise.
void	writeRow()	Writes out a new row (values set using setters).
void	writeTable(Table t, long offset, long length)

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, getRecordSetter, getRecordSetter, getRecordWriter, getSetter, writeDeferredRow, writeRecord

Constructor Details

StreamTableWriter

public StreamTableWriter(@NotNull
 TableDefinition definition,
 @NotNull
 com.fishlib.io.streams.CurrentByteBufferSink byteBufferSink)

Create a stream table writer that writes to the supplied sink.

Parameters:

definition - The table definition

byteBufferSink - The sink

Method Details

getSetter

public RowSetter getSetter(String name)

Description copied from interface: TableWriter

Gets a setter for a column.

The implementation is likely to delegate to Row.getSetter(String) in a default Row instance.

Specified by:

getSetter in interface Row

Specified by:

getSetter in interface TableWriter

Parameters:

name - column name

Returns:

setter for the column.

setFlags

public void setFlags(Row.Flags flags)

Description copied from interface: TableWriter

The implementation is likely to delegate to Row.setFlags(Flags) in a default Row instance.

Specified by:

setFlags in interface Row

Specified by:

setFlags in interface TableWriter

getRowWriter

public Row getRowWriter()

Description copied from interface: TableWriter

Get a writer for a Row entries. This is likely to be newly created, so callers should cache this value. In practice, TableWriter implementations generally cache the result of the first call to this method as a primary writer.

Specified by:

getRowWriter in interface TableWriter

Returns:

a Row, likely newly created

writeRow

public void writeRow()
              throws IOException

Description copied from interface: TableWriter

Writes out a new row (values set using setters).

The implementation is likely to delegate to Row.writeRow() in a default Row instance.

Specified by:

writeRow in interface Row

Specified by:

writeRow in interface TableWriter

Throws:

IOException - problem writing the row

flush

public void flush()

Description copied from interface: TableWriter

Flushes data out.

Specified by:

flush in interface TableWriter

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

Returns:

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

close

public void close()
           throws IOException

Description copied from interface: TableWriter

Closes the writer.

Specified by:

close in interface TableWriter

Throws:

IOException - problem closing the writer.

getColumnTypes

public Class[] getColumnTypes()

Description copied from interface: TableWriter

Gets the column types for the table.

Specified by:

getColumnTypes in interface TableWriter

Returns:

column types for the table.

getColumnNames

public String[] getColumnNames()

Description copied from interface: TableWriter

Gets the column names for the table.

Specified by:

getColumnNames in interface TableWriter

Returns:

column names for the table.

writeTable

public void writeTable(@NotNull
 Table t,
 long offset,
 long length)
                throws IOException

Throws:

IOException