Package io.deephaven.enterprise.table

Class InMemoryTableWriter

java.lang.Object
io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter
io.deephaven.enterprise.table.InMemoryTableWriter
All Implemented Interfaces:
io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Entry, io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Record, io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row, io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.TableWriter<io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row>, io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.BufferedAppendable
public final class InMemoryTableWriter extends io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter
a LocalTableWriter implementation which creates a Table with all column-data stored in memory

  • Nested Class Summary

    Nested classes/interfaces inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Record

    io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Record.RecordSetter<T extends io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.RecordData>

    Nested classes/interfaces inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row

    io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row.Flags

  • Field Summary

    Fields inherited from class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    invalidTransaction, NULL_PENDING_SIZE, pendingSize

    Fields inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.TableWriter

    NULL_SETTER

  • Constructor Summary

    Constructors
    Constructor
    Description
    InMemoryTableWriter(TableDefinition tableDefinition, Collection<String> symbolTableCols)
    Delegates to InMemoryTableWriter(TableDefinition, Collection, boolean) with needRowSupport=false
    InMemoryTableWriter(TableDefinition tableDefinition, Collection<String> symbolTableCols, boolean needRowSupport)
    Construct a new InMemoryTableWriter instance

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    abortTransaction()
     
    void
    adviseRowsWritten(long count)
     
    void
    close()
     
    boolean
    dirty()
     
    void
    endTransaction()
     
    void
    flush()
     
    void
    force()
     
    <CT extends io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalAppendableColumn<?>>
    CT
    getColumn(@NotNull String name, @NotNull Class<CT> clazz)
     
    String[]
    getColumnNames()
     
    Class[]
    getColumnTypes()
     
    io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.RowSetter<Object>
    getSetter(String name)
     
    static Set<String>
    getSymbolTableColumns(SchemaInternal schemaInternal)
    Return a Set of column names which use symbol tables based on a schema.
    Table
    getTable()
    Construct a Table from the previously read data
    void
    release()
     
    void
    setFlags(io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row.Flags flags)
     
    void
    setImportDetails(Properties importDetails)
     
    void
    setImportState(io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.ImportState importState)
     
    void
    startTransaction()
     
    void
    updateImportState(@NotNull UnaryOperator<io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.ImportState> updater)
     
    void
    writeRow()
     

    Methods inherited from class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    getRowWriter, inInvalidTransaction, inTransaction, maybeAbortTransaction, maybeEndTransaction, maybeStartTransaction, processFlagsPostWrite, processFlagsPreWrite, startInvalidTransaction, supportAllTypes

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.BufferedAppendable

    maybeForce, prepareCheckpoint

    Methods inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row

    getColumnPartitionValue, setColumnPartitionValue

    Methods inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.TableWriter

    flushDeferredRows, getRecordSetter, getRecordSetter, getRecordWriter, getSetter, writeDeferredRow, writeRecord

  • Constructor Details

  • Method Details

    • getColumn

      public <CT extends io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalAppendableColumn<?>> CT getColumn(@NotNull @NotNull String name, @NotNull @NotNull Class<CT> clazz)
      Specified by:
      getColumn in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • startTransaction

      public void startTransaction()
      Specified by:
      startTransaction in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • abortTransaction

      public void abortTransaction()
      Specified by:
      abortTransaction in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • endTransaction

      public void endTransaction()
      Specified by:
      endTransaction in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • adviseRowsWritten

      public void adviseRowsWritten(long count)
      Specified by:
      adviseRowsWritten in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • dirty

      public boolean dirty()
      Specified by:
      dirty in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • updateImportState

      public void updateImportState(@NotNull @NotNull UnaryOperator<io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.ImportState> updater)
      Specified by:
      updateImportState in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • setImportState

      public void setImportState(io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.dataimport.logtailer.ImportState importState)
      Specified by:
      setImportState in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • setImportDetails

      public void setImportDetails(Properties importDetails)
      Specified by:
      setImportDetails in class io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalTableWriter

    • getSetter

      public io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.RowSetter<Object> getSetter(String name)

    • setFlags

      public void setFlags(io.deephaven.shadow.enterprise.com.illumon.iris.binarystore.Row.Flags flags)

    • writeRow

      public void writeRow() throws IOException
      Throws:
      IOException

    • close

      public void close()

    • release

      public void release()

    • getColumnTypes

      public Class[] getColumnTypes()

    • getColumnNames

      public String[] getColumnNames()

    • flush

      public void flush()

    • force

      public void force()

    • getTable

      public Table getTable()
      Construct a Table from the previously read data
      Returns:
      a Table instance

    • getSymbolTableColumns

      public static Set<String> getSymbolTableColumns(SchemaInternal schemaInternal)
      Return a Set of column names which use symbol tables based on a schema.
      Parameters:
      schemaInternal - the SchemaInternal
      Returns:
      a possibly-empty set of column names which use symbol tables