Package com.illumon.iris.db.v2.utils

Class HybridWriter

java.lang.Object

com.illumon.iris.db.v2.utils.HybridWriter

All Implemented Interfaces:

Entry, Record, Row, TableWriter

public class HybridWriter
extends Object
implements TableWriter

TableWriter that writes to multiple other writers.

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
HybridWriter(TableWriter[] tableWriters)

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).

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

HybridWriter

public HybridWriter(TableWriter[] tableWriters)

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

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.

flush

public void flush() throws IOException

Description copied from interface: TableWriter

Flushes data out.

Specified by:

flush in interface TableWriter

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

Returns:

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