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