Package io.deephaven.barrage

Class BarrageSnapshotPerformanceLogger

java.lang.Object

com.illumon.intradaylogger.IntradayLoggerImpl2<io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter>

io.deephaven.barrage.BarrageSnapshotPerformanceLogger

All Implemented Interfaces:

IntradayLogger

public class BarrageSnapshotPerformanceLogger
extends IntradayLoggerImpl2<io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter>
implements IntradayLogger

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 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
BarrageSnapshotPerformanceLogger()

Method Summary

Modifier and Type	Method	Description
protected io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter	createSetter()
static String	getDefaultTableName()
static TableDefinition	getTableDefinition()
protected TableWriter	getTableWriter(IntradayLogger.TableWriterFactory tableWriterBuilder)
void	log(Row.Flags flags, String tableId, String tableKey, Instant requestTime, long queueNanos, long snapshotNanos, long writeNanos, long bytesWritten)
void	log(String tableId, String tableKey, Instant requestTime, long queueNanos, long snapshotNanos, long writeNanos, long bytesWritten)
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, getLogFormat, getWriterThread, init, init, init, init, isClosed, setOverflowThrottle, shutdown, tryWrite, usingDynamicPartitioning, waitDone, waitDone

Constructor Details

BarrageSnapshotPerformanceLogger

public BarrageSnapshotPerformanceLogger()

Method Details

getTableDefinition

public static TableDefinition getTableDefinition()

getDefaultTableName

public static String getDefaultTableName()

threadName

protected String threadName()

Specified by:

threadName in class IntradayLoggerImpl2<io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter>

createSetter

protected io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter createSetter()

Specified by:

createSetter in class IntradayLoggerImpl2<io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter>

verifyChecksum

protected void verifyChecksum()

Specified by:

verifyChecksum in class IntradayLoggerImpl2<io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter>

getTableWriter

protected TableWriter getTableWriter(IntradayLogger.TableWriterFactory tableWriterBuilder)

Specified by:

getTableWriter in class IntradayLoggerImpl2<io.deephaven.barrage.BarrageSnapshotPerformanceLogger.ISetter>

log

public void log(String tableId,
 String tableKey,
 Instant requestTime,
 long queueNanos,
 long snapshotNanos,
 long writeNanos,
 long bytesWritten)
         throws IOException

Throws:

IOException

log

public void log(Row.Flags flags,
 String tableId,
 String tableKey,
 Instant requestTime,
 long queueNanos,
 long snapshotNanos,
 long writeNanos,
 long bytesWritten)
         throws IOException

Throws:

IOException