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

Class BinaryReaderToTableWriter

java.lang.Object

com.illumon.iris.db.tables.dataimport.logtailer.BinaryReaderToTableWriter

All Implemented Interfaces:

TableListener

public class BinaryReaderToTableWriter
extends Object
implements TableListener

Constructor Summary

Constructors

Constructor	Description
BinaryReaderToTableWriter()

Method Summary

Modifier and Type	Method	Description
void	close()	Close this listener when no further rows will be supplied.
TableDefinition	getTableDefinition()	Get the TableDefinition that specifies the columns this table listener expects to supply to its writer.
void	init(TableReader reader)	Specify the reader to be used for subsequent rows.
void	onNewRow()	Called by the driving application whenever a new row that is available from the reader.
ImportState	resumeReading(ImportState importState)	Allow the driving application to supply a listener with its import state object.
void	setWriter(TableWriter writer)	Supply the writer for output.
void	setWriter(TableWriter writer, DbTableLocation unused)	Supply the writer for output.

Methods inherited from class java.lang.Object

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

Constructor Details

BinaryReaderToTableWriter

public BinaryReaderToTableWriter()

Method Details

init

public void init(TableReader reader)

Description copied from interface: TableListener

Specify the reader to be used for subsequent rows. Typically allows listeners to obtain RowGetters for each relevant column.

Specified by:

init in interface TableListener

Parameters:

reader - The reader

onNewRow

public void onNewRow()

Description copied from interface: TableListener

Called by the driving application whenever a new row that is available from the reader.

Specified by:

onNewRow in interface TableListener

setWriter

public void setWriter(TableWriter writer, DbTableLocation unused)

Description copied from interface: TableListener

Supply the writer for output. Typically allows listeners to obtain RowSetters for each relevant column.

Specified by:

setWriter in interface TableListener

Parameters:

writer - The writer

unused - The table location object, typically used only for import details output on close

setWriter

public void setWriter(TableWriter writer)

Description copied from interface: TableListener

Supply the writer for output. Typically allows listeners to obtain RowSetters for each relevant column.

Specified by:

setWriter in interface TableListener

Parameters:

writer - The writer

close

public void close() throws IOException

Description copied from interface: TableListener

Close this listener when no further rows will be supplied.

Specified by:

close in interface TableListener

Throws:

IOException

resumeReading

public ImportState resumeReading(ImportState importState)

Description copied from interface: TableListener

Allow the driving application to supply a listener with its import state object.

Specified by:

resumeReading in interface TableListener

Parameters:

importState - The import state object, or null if none exists

getTableDefinition

public TableDefinition getTableDefinition()

Description copied from interface: TableListener

Get the TableDefinition that specifies the columns this table listener expects to supply to its writer.

Note that this should only include writable columns, and that listener implementations are only required to accurately describe the column names (DefaultColumnDefinition.getName()) and data types (ColumnDefinition.getDataType()) they expect to supply.

Specified by:

getTableDefinition in interface TableListener

Returns:

The supported TableDefinition.