com.illumon.iris.db.tables.dataimport

Interface TableLoggerBase

All Known Subinterfaces:

TableLogger

All Known Implementing Classes:

JdbcLogger

public interface TableLoggerBase

A base interface for loggers that log snapshots and/or updates to Deephaven tables. Implementations of this may target either another Deephaven table or external consumers. For convenience, a number of default methods are provided that delegate to the final implementation of the logTable method.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TableLoggerBase.Flags Flags for controlling the transactional behavior of this log call.
static interface	TableLoggerBase.Handle Marker interface for log handles
static class	TableLoggerBase.Operation Indicator of the source table update event that resulted in a log call.

Method Summary

Modifier and Type	Method and Description
TableLoggerBase.Handle	getLogHandle(Table tableToLog) Gets a handle suitable for use with logTableHandle.
default void	logTable(Table tableToLog) Writes a snapshot of tableToLog to the target.
default void	logTable(Table tableToLog, Index index) Writes a subset of tableToLog to the binary log.
void	logTable(Table tableToLog, Index index, TableLoggerBase.Flags flags, boolean logUpdates, boolean logPrevValues) Writes tableToLog to the target.
default void	logTable(Table tableToLog, TableLoggerBase.Flags flags) Writes a snapshot of tableToLog to the target.
default void	logTable(Table tableToLog, TableLoggerBase.Flags flags, boolean logUpdates) Writes tableToLog to the target.
default void	logTable(Table tableToLog, TableLoggerBase.Flags flags, boolean logUpdates, boolean logPrevValues) Writes tableToLog to the target.
default void	logTable(Table tableToLog, TableLoggerBase.Flags flags, Index index) Writes a subset of tableToLog to the target.

Method Detail

logTable

void logTable(Table tableToLog,
              Index index,
              TableLoggerBase.Flags flags,
              boolean logUpdates,
              boolean logPrevValues)

Writes tableToLog to the target. Optionally, continue to listen for updates and log them.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

index - the subset of the table to log

flags - controls the transaction behavior

logUpdates - if true, continue to log updates to the table

logPrevValues - if true, log the old version of each row when rows are modified (only applicable when logUpdates is true)

Throws:

IOException - if the log call fails

logTable

default void logTable(Table tableToLog,
                      TableLoggerBase.Flags flags,
                      boolean logUpdates,
                      boolean logPrevValues)

Writes tableToLog to the target. Optionally, continue to listen for updates and log them.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

flags - controls the transaction behavior

logUpdates - if true, continue to log updates to the table

logPrevValues - if true, log the old version of each row when rows are modified (only applicable when logUpdates is true)

Throws:

IOException - if the log call fails

logTable

default void logTable(Table tableToLog,
                      TableLoggerBase.Flags flags,
                      Index index)

Writes a subset of tableToLog to the target.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

flags - controls the transaction behavior

index - the subset of the table to log

Throws:

IOException - if the log call fails

logTable

default void logTable(Table tableToLog,
                      TableLoggerBase.Flags flags,
                      boolean logUpdates)

Writes tableToLog to the target. Optionally, continue to listen for updates and log them. Delegates to TableLoggerBase.logTable(Table,Flags,boolean,boolean) with logPrevValues set to true.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

flags - controls the transaction behavior

logUpdates - if true, continue to log updates to the table

Throws:

IOException - if the log call fails

logTable

default void logTable(Table tableToLog,
                      TableLoggerBase.Flags flags)

Writes a snapshot of tableToLog to the target. Delegates to TableLoggerBase.logTable(Table, Flags, boolean, boolean) with logUpdates and logPrevValues set to false.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

flags - controls the transaction behavior

Throws:

IOException - if the log call fails

logTable

default void logTable(Table tableToLog)

Writes a snapshot of tableToLog to the target. Delegates to TableLoggerBase.logTable(Table, Flags) with flags set to TableLoggerBase.DEFAULT_TABLELOGGER_FLAGS.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

Throws:

IOException - if the log call fails

logTable

default void logTable(Table tableToLog,
                      Index index)

Writes a subset of tableToLog to the binary log. Delegates to TableLoggerBase.logTable(Table, Flags, Index) with flags set to TableLoggerBase.DEFAULT_TABLELOGGER_FLAGS.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

index - which rows to log from the table (initial snapshot only)

Throws:

IOException

getLogHandle

TableLoggerBase.Handle getLogHandle(Table tableToLog)

Gets a handle suitable for use with logTableHandle. If you are repeatedly logging rows from a table, it is more efficient to check the definition once rather than on each log call.

Parameters:

tableToLog - the table to log, must conform to the definition used to create this logger

Returns:

a handle that can be passed into logTableHandle