Package io.deephaven.enterprise.binlog.internal.gen

Class ServerStateLoggerCoreV2

java.lang.Object

io.deephaven.enterprise.binlog.buffered.impl.MultiPartitionLoggerThreadSafeBase

io.deephaven.enterprise.binlog.internal.gen.ServerStateLoggerCoreV2

All Implemented Interfaces:

Logger, Closeable, Flushable, AutoCloseable

public final class ServerStateLoggerCoreV2
extends MultiPartitionLoggerThreadSafeBase

Automatically generated Deephaven binary logger for DbInternal.ServerStateLogCoreV2 format 1. For configuration details, see `io.deephaven.enterprise.schema.internal.LogFormat`

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	ServerStateLoggerCoreV2.HeaderEncoder	The header encoder.
static final class	ServerStateLoggerCoreV2.RowEncoder	The row encoder.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BUFFER_SIZE
static final byte	FLAG_END	Flag indicating that this row is the end of a transaction.
static final byte	FLAG_NONE	Flag indicating that this row is neither the beginning nor end of a transaction.
static final byte	FLAG_SINGLE_ROW	Flag indicating that this row is the beginning and end of a transaction.
static final byte	FLAG_START	Flag indicating that this row is the beginning of a transaction.
static final boolean	IS_SYSTEM_NAMESPACE	If this is a System namespace
static final int	LOG_FORMAT	The log format version
static final int	MAX_ENTRY_SIZE
static final String	NAMESPACE	The Namespace
static final String	TABLE_NAME	The TableName

Method Summary

Modifier and Type	Method	Description
protected final void	abortBuffer()
protected final void	commitBuffer()
protected final void	commitBuffers(int arg0)
static ByteBuffer	header(String AuthenticatedUser, String EffectiveUser, String ProcessInfoId)
void	log(String Date, byte flags, long IntervalStartTime, int IntervalDurationMicros, int TotalMemoryMiB, int FreeMemoryMiB, short IntervalCollections, int IntervalCollectionTimeMicros, short IntervalUGPCyclesOnBudget, int[] IntervalUGPCyclesTimeMicros, short IntervalUGPCyclesSafePoints, int IntervalUGPCyclesSafePointTimeMicros)	Encodes the data into this logger's buffer.
static LoggerInfo<ServerStateLoggerCoreV2>	loggerInfo()	The basic logger information.
static ServerStateLoggerCoreV2	of(boolean flushOnLog, MultiPartitionWriter writer)	Initialize a logger for the DbInternal.ServerStateLogCoreV2 table, with log format 1.
protected final void	partition(String arg0)
protected final ByteBuffer	takeBuffer()
String	toString()

Methods inherited from class io.deephaven.enterprise.binlog.buffered.impl.MultiPartitionLoggerThreadSafeBase

close, flush

Methods inherited from class java.lang.Object

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

Field Details

FLAG_NONE

public static final byte FLAG_NONE

Flag indicating that this row is neither the beginning nor end of a transaction.

See Also:

• Constant Field Values

FLAG_START

public static final byte FLAG_START

Flag indicating that this row is the beginning of a transaction.

See Also:

• Constant Field Values

FLAG_END

public static final byte FLAG_END

Flag indicating that this row is the end of a transaction.

See Also:

• Constant Field Values

FLAG_SINGLE_ROW

public static final byte FLAG_SINGLE_ROW

Flag indicating that this row is the beginning and end of a transaction.

See Also:

• Constant Field Values

IS_SYSTEM_NAMESPACE

public static final boolean IS_SYSTEM_NAMESPACE

If this is a System namespace

See Also:

• Constant Field Values

NAMESPACE

public static final String NAMESPACE

The Namespace

See Also:

• Constant Field Values

TABLE_NAME

public static final String TABLE_NAME

The TableName

See Also:

• Constant Field Values

LOG_FORMAT

public static final int LOG_FORMAT

The log format version

See Also:

• Constant Field Values

MAX_ENTRY_SIZE

public static final int MAX_ENTRY_SIZE

See Also:

• Constant Field Values

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

• Constant Field Values

Method Details

header

public static ByteBuffer header(String AuthenticatedUser,
 String EffectiveUser,
 String ProcessInfoId)

of

public static ServerStateLoggerCoreV2 of(boolean flushOnLog,
 MultiPartitionWriter writer)

Initialize a logger for the DbInternal.ServerStateLogCoreV2 table, with log format 1. The returned logger will own a byte array buffer of size 2 MiB (`bufferSize`) when flushOnLog == false, otherwise 1 MiB (`maxEntrySize`).

Parameters:

flushOnLog - if the returned logger should be flushed on every log call

writer - the writer for this logger

Returns:

the logger

log

public void log(String Date,
 byte flags,
 long IntervalStartTime,
 int IntervalDurationMicros,
 int TotalMemoryMiB,
 int FreeMemoryMiB,
 short IntervalCollections,
 int IntervalCollectionTimeMicros,
 short IntervalUGPCyclesOnBudget,
 int[] IntervalUGPCyclesTimeMicros,
 short IntervalUGPCyclesSafePoints,
 int IntervalUGPCyclesSafePointTimeMicros)
         throws IOException

Encodes the data into this logger's buffer. If the remaining size of the buffer after logging is less than 1 MiB (`maxEntrySize`), this logger will be internally flushed.

Parameters:

Date - the partition

flags - the flags for this row, which start and end transactions

IntervalStartTime - the IntervalStartTime value, in millis from the epoch

IntervalDurationMicros - the IntervalDurationMicros value

TotalMemoryMiB - the TotalMemoryMiB value

FreeMemoryMiB - the FreeMemoryMiB value

IntervalCollections - the IntervalCollections value

IntervalCollectionTimeMicros - the IntervalCollectionTimeMicros value

IntervalUGPCyclesOnBudget - the IntervalUGPCyclesOnBudget value

IntervalUGPCyclesTimeMicros - the IntervalUGPCyclesTimeMicros value

IntervalUGPCyclesSafePoints - the IntervalUGPCyclesSafePoints value

IntervalUGPCyclesSafePointTimeMicros - the IntervalUGPCyclesSafePointTimeMicros value

Throws:

IOException

loggerInfo

public static LoggerInfo<ServerStateLoggerCoreV2> loggerInfo()

The basic logger information.

Returns:

the basic logger information

toString

public String toString()

Overrides:

toString in class Object

partition

protected final void partition(String arg0)
                        throws IOException

Throws:

IOException

takeBuffer

protected final ByteBuffer takeBuffer()
                               throws IOException

Throws:

IOException

abortBuffer

protected final void abortBuffer()

commitBuffer

protected final void commitBuffer()
                           throws IOException

Throws:

IOException

commitBuffers

protected final void commitBuffers(int arg0)
                            throws IOException

Throws:

IOException