Package com.illumon.iris.db.gen

Class ProcessTelemetryIndexLogger

java.lang.Object

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

com.illumon.iris.db.gen.ProcessTelemetryIndexLogger

All Implemented Interfaces:

IntradayLogger, TwoArgLogger<String,ArrayTuple>

public class ProcessTelemetryIndexLogger
extends IntradayLoggerImpl2<com.illumon.iris.db.gen.ProcessTelemetryIndexLogger.ISetter>
implements TwoArgLogger<String,ArrayTuple>

Nested Class Summary

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

IntradayLoggerImpl2.BaseSetter<T2 extends IntradayLoggerImpl2<T>.BaseSetter<T2>>

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

IntradayLogger.TableWriterFactory, IntradayLogger.TableWriterFactoryImpl

Field Summary

Fields

Modifier and Type	Field	Description
static final long	_CLASS_BODY_CRC32_
static final 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

Constructor Summary

Constructors

Constructor	Description
ProcessTelemetryIndexLogger()

Method Summary

Modifier and Type	Method	Description
protected com.illumon.iris.db.gen.ProcessTelemetryIndexLogger.ISetter	createSetter()
static String	getDefaultNamespace()
static String	getDefaultTableName()
int	getLogFormat()	Get the log format (also called "application version") for this logger.
protected TableWriter	getTableWriter(IntradayLogger.TableWriterFactory tableWriterBuilder)
void	log(Row.Flags flags, String InternalPartition, ArrayTuple Tuple)
void	log(String InternalPartition, ArrayTuple Tuple)
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

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

ProcessTelemetryIndexLogger

public ProcessTelemetryIndexLogger()

Method Details

getLogFormat

public int getLogFormat()

Description copied from interface: IntradayLogger

Get the log format (also called "application version") for this logger. May be used, for example, to segment log streams into multiple partitions by log format as part of a rollout strategy for new schema versions.

Specified by:

getLogFormat in interface IntradayLogger

Returns:

The log format number

getDefaultNamespace

public static String getDefaultNamespace()

getDefaultTableName

public static String getDefaultTableName()

verifyChecksum

protected void verifyChecksum()
                       throws IOException

Specified by:

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

Throws:

IOException

threadName

protected String threadName()

Specified by:

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

getTableWriter

protected TableWriter getTableWriter(IntradayLogger.TableWriterFactory tableWriterBuilder)
                              throws IOException

Specified by:

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

Throws:

IOException

createSetter

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

Specified by:

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

log

public void log(String InternalPartition,
 ArrayTuple Tuple)
         throws IOException

Specified by:

log in interface TwoArgLogger<String,ArrayTuple>

Throws:

IOException

log

public void log(Row.Flags flags,
 String InternalPartition,
 ArrayTuple Tuple)
         throws IOException

Specified by:

log in interface TwoArgLogger<String,ArrayTuple>

Throws:

IOException