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

Class BinaryRowLoggerDnd

java.lang.Object
io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowLoggerDnd
Direct Known Subclasses:
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
     
    static String
    CURRENT_DATE_SENTINEL
    Sentinel Object for current date partitioning.
    protected final io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.logaggregator.BinaryStoreAggregatorWriterMultiPartition
    lasTableWriter
     
    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()
     

    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

    • lasTableWriter

      protected final io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.logaggregator.BinaryStoreAggregatorWriterMultiPartition lasTableWriter

    • 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