Package com.illumon.iris.db.gen

Class ProcessTelemetryFormat1Logger

java.lang.Object

com.illumon.intradaylogger.IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter>

com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger

All Implemented Interfaces:

com.illumon.intradaylogger.IntradayLogger, TableLogger, TableLoggerBase

public class ProcessTelemetryFormat1Logger
extends com.illumon.intradaylogger.IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter>
implements TableLogger

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.intradaylogger.IntradayLoggerImpl2

com.illumon.intradaylogger.IntradayLoggerImpl2.BaseSetter<T2 extends com.illumon.intradaylogger.IntradayLoggerImpl2.BaseSetter<T2>>

Nested classes/interfaces inherited from interface com.illumon.intradaylogger.IntradayLogger

com.illumon.intradaylogger.IntradayLogger.TableWriterFactory, com.illumon.intradaylogger.IntradayLogger.TableWriterFactoryImpl

Nested classes/interfaces inherited from interface com.illumon.iris.db.tables.dataimport.TableLogger

TableLogger.NoPrevColumnSource<T>

Nested classes/interfaces inherited from interface com.illumon.iris.db.tables.dataimport.TableLoggerBase

TableLoggerBase.Flags, TableLoggerBase.Operation

Field Summary

Fields

Modifier and Type	Field	Description
static long	_CLASS_BODY_CRC32_
static String	_SCHEMA_

Fields inherited from class com.illumon.intradaylogger.IntradayLoggerImpl2

forceStandaloneMode, isClosed, isShuttingDown, outstandingSetters, setterPool, verifyChecksumDisabled, writer

Fields inherited from interface com.illumon.intradaylogger.IntradayLogger

DEFAULT_INTRADAY_LOGGER_FLAGS

Fields inherited from interface com.illumon.iris.db.tables.dataimport.TableLoggerBase

DEFAULT_TABLELOGGER_FLAGS

Constructor Summary

Constructors

Constructor	Description
ProcessTelemetryFormat1Logger()

Method Summary

Modifier and Type	Method	Description
protected com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter	createSetter()
static String	getDefaultNamespace()
static String	getDefaultTableName()
int	getLogFormat()
com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.Handle	getLogHandle(Table tableToLog, Collection<String> logPrevColumns)	Gets a handle suitable for use with logTableHandle.
protected TableWriter	getTableWriter(com.illumon.intradaylogger.IntradayLogger.TableWriterFactory tableWriterBuilder)
TableWriter	getWriter()	Return the table writer.
void	logTableHandle(TableLoggerBase.Handle logHandle, Row.Flags flags, long index, TableLoggerBase.Operation operation)	Log a row from a table handle
void	logTableHandlePrev(TableLoggerBase.Handle logHandle, Row.Flags flags, long index, TableLoggerBase.Operation operation)	Log a previous row from a table handle
protected String	threadName()
protected void	verifyChecksum()

Methods inherited from class com.illumon.intradaylogger.IntradayLoggerImpl2

close, disableVerifyChecksum, flush, getWriterThread, init, init, init, init, isClosed, isInitialized, setOverflowThrottle, setStandaloneMode, shutdown, tryWrite, verifyCondition, waitDone, waitDone

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.intradaylogger.IntradayLogger

close, getWriterThread, init, init, init, init, isClosed, setOverflowThrottle, shutdown, tryWrite, usingDynamicPartitioning, waitDone, waitDone

Methods inherited from interface com.illumon.iris.db.tables.dataimport.TableLogger

logTable, logTable

Methods inherited from interface com.illumon.iris.db.tables.dataimport.TableLoggerBase

logTable, logTable, logTable, logTable, logTable, logTable, logTable

Field Details

_SCHEMA_

public static final String _SCHEMA_

See Also:

Constant Field Values

_CLASS_BODY_CRC32_

public static final long _CLASS_BODY_CRC32_

See Also:

Constant Field Values

Constructor Details

ProcessTelemetryFormat1Logger

public ProcessTelemetryFormat1Logger()

Method Details

getLogFormat

public int getLogFormat()

Specified by:

getLogFormat in interface com.illumon.intradaylogger.IntradayLogger

getDefaultNamespace

public static String getDefaultNamespace()

getDefaultTableName

public static String getDefaultTableName()

verifyChecksum

protected void verifyChecksum() throws IOException

Specified by:

verifyChecksum in class com.illumon.intradaylogger.IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter>

Throws:

IOException

threadName

protected String threadName()

Specified by:

threadName in class com.illumon.intradaylogger.IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter>

getTableWriter

protected TableWriter getTableWriter(com.illumon.intradaylogger.IntradayLogger.TableWriterFactory tableWriterBuilder) throws IOException

Specified by:

getTableWriter in class com.illumon.intradaylogger.IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter>

Throws:

IOException

createSetter

protected com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter createSetter()

Specified by:

createSetter in class com.illumon.intradaylogger.IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.ISetter>

getLogHandle

public com.illumon.iris.db.gen.ProcessTelemetryFormat1Logger.Handle getLogHandle(Table tableToLog, Collection<String> logPrevColumns)

Description copied from interface: TableLoggerBase

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.

Specified by:

getLogHandle in interface TableLoggerBase

Parameters:

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

logPrevColumns - if not null, gives the columns for which to log previous values on remove and row modification

Returns:

a handle that can be passed into logTableHandle, with dummy column sources for previous columns not specified

logTableHandle

public void logTableHandle(TableLoggerBase.Handle logHandle, Row.Flags flags, long index, TableLoggerBase.Operation operation) throws IOException

Description copied from interface: TableLogger

Log a row from a table handle

Specified by:

logTableHandle in interface TableLogger

Parameters:

logHandle - the log handle to extract data from

flags - controls the transaction behavior

index - the row (index key) to log

operation - the table update event that resulted in this log call

Throws:

IOException - if the log call fails

logTableHandlePrev

public void logTableHandlePrev(TableLoggerBase.Handle logHandle, Row.Flags flags, long index, TableLoggerBase.Operation operation) throws IOException

Description copied from interface: TableLogger

Log a previous row from a table handle

Specified by:

logTableHandlePrev in interface TableLogger

Parameters:

logHandle - the log handle to extract data from

flags - controls the transaction behavior

index - the row (index key) to log

operation - the table update event that resulted in this log call

Throws:

IOException - if the log call fails

getWriter

public TableWriter getWriter()

Description copied from interface: TableLogger

Return the table writer. This will have been created by the created by the TableWriterFactory during init().

Specified by:

getWriter in interface TableLogger

Returns:

the internal TableWriter, or null if the implementation does not support this call.