Package io.deephaven.barrage

Class BarrageSubscriptionPerformanceLogger

java.lang.Object

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

io.deephaven.barrage.BarrageSubscriptionPerformanceLogger

All Implemented Interfaces:

IntradayLogger

public class BarrageSubscriptionPerformanceLogger
extends IntradayLoggerImpl2<io.deephaven.barrage.BarrageSubscriptionPerformanceLogger.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
BarrageSubscriptionPerformanceLogger()

Method Summary

Modifier and Type	Method	Description
protected io.deephaven.barrage.BarrageSubscriptionPerformanceLogger.ISetter	createSetter()
static String	getDefaultTableName()
static TableDefinition	getTableDefinition()
protected TableWriter	getTableWriter(IntradayLogger.TableWriterFactory tableWriterBuilder)
void	log(Row.Flags flags, String tableId, String tableKey, String statType, Instant time, long count, double pct50, double pct75, double pct90, double pct95, double pct99, double max)
void	log(String tableId, String tableKey, String statType, Instant time, long count, double pct50, double pct75, double pct90, double pct95, double pct99, double max)
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

BarrageSubscriptionPerformanceLogger

public BarrageSubscriptionPerformanceLogger()

Method Details

getDefaultTableName

public static String getDefaultTableName()

getTableDefinition

public static TableDefinition getTableDefinition()

threadName

protected String threadName()

Specified by:

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

createSetter

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

Specified by:

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

verifyChecksum

protected void verifyChecksum()

Specified by:

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

getTableWriter

protected TableWriter getTableWriter(IntradayLogger.TableWriterFactory tableWriterBuilder)

Specified by:

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

log

public void log(String tableId,
 String tableKey,
 String statType,
 Instant time,
 long count,
 double pct50,
 double pct75,
 double pct90,
 double pct95,
 double pct99,
 double max)
         throws IOException

Throws:

IOException

log

public void log(Row.Flags flags,
 String tableId,
 String tableKey,
 String statType,
 Instant time,
 long count,
 double pct50,
 double pct75,
 double pct90,
 double pct95,
 double pct99,
 double max)
         throws IOException

Throws:

IOException