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

Class BinaryRowUtils

java.lang.Object
io.deephaven.enterprise.dnd.logger.engine.impl.BinaryRowUtils
@InternalUseOnly public class BinaryRowUtils extends Object

  • Method Summary

    Modifier and Type
    Method
    Description
    static io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row.Flags
    adaptFlags(Row.Flags flags)
    Adapt flags from Community Core to Enterprise Shadowed flags.
    static byte
    adaptFlagsV2(Row.Flags flags)
    Adapt flags from Community Core to Enterprise V2 BLF flags.
    static DateTimeFormatter
    getDateTimeFormatter()
    Get partition date time formatter.
    static String
    getPartitionFromMillis(long millis)
    Generate string date partition from millisecond timestamp.
    static String
    getPartitionFromNanos(long nanos)
    Generate string date partition from nanosecond timestamp.
    static io.deephaven.enterprise.binlog.support.MultiPartitionBufferWriter
    makeBinaryWriter(@NotNull io.deephaven.enterprise.binlog.support.LoggerInfo generatedLogger)
    Create a writer for Core+ worker internal logging.
    static io.deephaven.enterprise.binlog.support.MultiPartitionBufferWriter
    makeBinaryWriter(@NotNull io.deephaven.enterprise.binlog.support.LoggerInfo generatedLogger, @NotNull String processName)
    Create a writer for Core+ worker internal logging.

    Methods inherited from class java.lang.Object

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

  • Method Details

    • getDateTimeFormatter

      public static DateTimeFormatter getDateTimeFormatter()
      Get partition date time formatter.
      Returns:
      partition date time formatter

    • makeBinaryWriter

      public static io.deephaven.enterprise.binlog.support.MultiPartitionBufferWriter makeBinaryWriter(@NotNull @NotNull io.deephaven.enterprise.binlog.support.LoggerInfo generatedLogger) throws IOException
      Create a writer for Core+ worker internal logging.
      Parameters:
      generatedLogger - the generated logger to be associated with the writer
      Returns:
      the writer associated with the generated logger
      Throws:
      IOException - when the log sink cannot be initialized

    • makeBinaryWriter

      public static io.deephaven.enterprise.binlog.support.MultiPartitionBufferWriter makeBinaryWriter(@NotNull @NotNull io.deephaven.enterprise.binlog.support.LoggerInfo generatedLogger, @NotNull @NotNull String processName) throws IOException
      Create a writer for Core+ worker internal logging.
      Parameters:
      generatedLogger - the generated logger to be associated with the writer
      processName - the process name to use
      Returns:
      the writer associated with the generated logger
      Throws:
      IOException - when the log sink cannot be initialized

    • getPartitionFromMillis

      public static String getPartitionFromMillis(long millis)
      Generate string date partition from millisecond timestamp.
      Parameters:
      millis - millisecond timestamp
      Returns:
      string date partition

    • getPartitionFromNanos

      public static String getPartitionFromNanos(long nanos)
      Generate string date partition from nanosecond timestamp.
      Parameters:
      nanos - nanosecond timestamp
      Returns:
      string date partition

    • adaptFlags

      public static io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row.Flags adaptFlags(@NotNull Row.Flags flags)
      Adapt flags from Community Core to Enterprise Shadowed flags.
      Parameters:
      flags - Core flags
      Returns:
      corresponding Enterprise flags

    • adaptFlagsV2

      public static byte adaptFlagsV2(@NotNull Row.Flags flags)
      Adapt flags from Community Core to Enterprise V2 BLF flags.
      Parameters:
      flags - Core flags
      Returns:
      corresponding Enterprise flags