Package io.deephaven.enterprise.ingester.impl

Class TableWriterContext

java.lang.Object
io.deephaven.enterprise.ingester.impl.TableWriterContext
public class TableWriterContext extends Object
Holder for a TableWriter and the processor for use in implementing an ingester.

Note: This class is not part of the public Deephaven Core+ API.

  • Constructor Summary

    Constructors
    Constructor
    Description
    TableWriterContext(@NotNull Logger logger, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.SimpleDataImportStreamProcessor disProcessor, @Nullable Runnable postPrepareCheckpointCallback, @Nullable Runnable postCommitCheckpointCallback, @NotNull String description, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition definitionToWrite, @NotNull Set<String> ignoredColumns, @NotNull List<ImportStateDetails> importStateDetails)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.SimpleDataImportStreamProcessor
    getDisProcessor()
     
    io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.FullTableLocationKey
    getStreamKey()
     
    io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter
    getTableWriter()
     
    void
    setWriterCheckpointRecord(@Nullable io.deephaven.shadow.enterprise.io.deephaven.csv.util.MutableObject<io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.CheckpointRecord.SourceFileSizeRecord> sfr, @NotNull Supplier<io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.CheckpointRecord.SourceFileSizeRecord> makeSourceFileSizeRecord)
    Set the checkpoint record to our tableWriterStreamConsumer, done outside the constructor so that we can read it in first.
    void
    writeChunkData(WritableChunk<Values>[] data, int offset, int size)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • TableWriterContext

      public TableWriterContext(@NotNull @NotNull Logger logger, @NotNull @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.SimpleDataImportStreamProcessor disProcessor, @Nullable @Nullable Runnable postPrepareCheckpointCallback, @Nullable @Nullable Runnable postCommitCheckpointCallback, @NotNull @NotNull String description, @NotNull @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition definitionToWrite, @NotNull @NotNull Set<String> ignoredColumns, @NotNull @NotNull List<ImportStateDetails> importStateDetails)

  • Method Details

    • setWriterCheckpointRecord

      public void setWriterCheckpointRecord(@Nullable @Nullable io.deephaven.shadow.enterprise.io.deephaven.csv.util.MutableObject<io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.CheckpointRecord.SourceFileSizeRecord> sfr, @NotNull @NotNull Supplier<io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.local.CheckpointRecord.SourceFileSizeRecord> makeSourceFileSizeRecord)
      Set the checkpoint record to our tableWriterStreamConsumer, done outside the constructor so that we can read it in first.
      Parameters:
      sfr - the existing source file record from the checkpoint
      makeSourceFileSizeRecord - a Supplier for the source file size record used while initializing the new partition

    • writeChunkData

      public void writeChunkData(WritableChunk<Values>[] data, int offset, int size)

    • getDisProcessor

      public io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.SimpleDataImportStreamProcessor getDisProcessor()

    • getTableWriter

      public io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter getTableWriter()

    • getStreamKey

      public io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.FullTableLocationKey getStreamKey()