Package io.deephaven.enterprise.dnd.logger.engine.impl

Class BinaryRowLoggerDnd

java.lang.Object

io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowLoggerDnd

Direct Known Subclasses:

ProcessMetricsLogLoggerDndImpl, SimpleAuditEventLogger

@InternalUseOnly
public abstract class BinaryRowLoggerDnd
extends Object

Base implementation for DnD components to log binary rows via LAS.

Field Summary

Fields

Modifier and Type	Field	Description
protected final io.deephaven.shadow.enterprise.com.illumon.util.pool.ThreadSafeLenientFixedSizePool<io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.BinaryRowV2>	binaryRowPool
protected final io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.BinaryStoreWriterV2	binaryTableWriter
static String	CURRENT_DATE_SENTINEL	Sentinel Object for current date partitioning.
protected final DateTimeFormatter	partitionFormatter

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	BinaryRowLoggerDnd(@NotNull String namespace, @NotNull String tableName, @NotNull String[] columnNames, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.SupportedType[] intradayTypes, @NotNull Object[] typeMetadata, @Nullable Map<String,Object> constantValues, int applicationVersion, boolean useLas, @Nullable String logDirectory, @NotNull ZoneId zoneId, io.deephaven.shadow.enterprise.com.illumon.util.db.TableIdentifier.NamespaceSet namespaceSet, @NotNull String internalPartition, @Nullable String columnPartition)
protected	BinaryRowLoggerDnd(@NotNull String namespace, @NotNull String tableName, @NotNull String[] columnNames, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.SupportedType[] intradayTypes, @NotNull Object[] typeMetadata, @Nullable Map<String,Object> constantValues, int applicationVersion, io.deephaven.shadow.enterprise.com.illumon.util.db.TableIdentifier.NamespaceSet namespaceSet)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the table writer.

Methods inherited from class java.lang.Object

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

Field Details

binaryRowPool

protected final io.deephaven.shadow.enterprise.com.illumon.util.pool.ThreadSafeLenientFixedSizePool<io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.BinaryRowV2> binaryRowPool

binaryTableWriter

protected final io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.BinaryStoreWriterV2 binaryTableWriter

partitionFormatter

protected final DateTimeFormatter partitionFormatter

CURRENT_DATE_SENTINEL

public static String CURRENT_DATE_SENTINEL

Sentinel Object for current date partitioning.

Constructor Details

BinaryRowLoggerDnd

protected BinaryRowLoggerDnd(@NotNull
 @NotNull String namespace,
 @NotNull
 @NotNull String tableName,
 @NotNull
 @NotNull String[] columnNames,
 @NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.SupportedType[] intradayTypes,
 @NotNull
 @NotNull Object[] typeMetadata,
 @Nullable
 @Nullable Map<String,Object> constantValues,
 int applicationVersion,
 @NotNull
 io.deephaven.shadow.enterprise.com.illumon.util.db.TableIdentifier.NamespaceSet namespaceSet)

BinaryRowLoggerDnd

protected BinaryRowLoggerDnd(@NotNull
 @NotNull String namespace,
 @NotNull
 @NotNull String tableName,
 @NotNull
 @NotNull String[] columnNames,
 @NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.SupportedType[] intradayTypes,
 @NotNull
 @NotNull Object[] typeMetadata,
 @Nullable
 @Nullable Map<String,Object> constantValues,
 int applicationVersion,
 boolean useLas,
 @Nullable
 @Nullable String logDirectory,
 @NotNull
 @NotNull ZoneId zoneId,
 @NotNull
 io.deephaven.shadow.enterprise.com.illumon.util.db.TableIdentifier.NamespaceSet namespaceSet,
 @NotNull
 @NotNull String internalPartition,
 @Nullable
 @Nullable String columnPartition)

Method Details

close

public void close()
           throws IOException

Close the table writer.

Throws:

IOException - problem closing the writer.