Package io.deephaven.importers

Class PreviewImportTableWriterFactoryLocalAppendable

java.lang.Object
io.deephaven.importers.PreviewImportTableWriterFactoryBase<File>
io.deephaven.importers.PreviewImportTableWriterFactoryLocalAppendable
All Implemented Interfaces:
ImportTableWriterFactory
public class PreviewImportTableWriterFactoryLocalAppendable extends PreviewImportTableWriterFactoryBase<File>
ImportTableWriterFactory implementation used in Preview Import Table functionality, for use with LocalAppendableTable functionality.

  • Constructor Details

    • PreviewImportTableWriterFactoryLocalAppendable

      public PreviewImportTableWriterFactoryLocalAppendable(@NotNull @NotNull Schema schema, @NotNull @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition, @NotNull @NotNull String internalPartitionValue, @Nullable @Nullable String singlePartitionColumnPartitionValue)
      Constructor.
      Parameters:
      schema - the Schema for the table being imported
      tableDefinition - the TableDefinition
      internalPartitionValue - the internal partition used in creating the location key for each partition
      singlePartitionColumnPartitionValue - optional partition value to use, must be specified in case of a single partition value imports

  • Method Details

    • getTableDestination

      @NotNull public @NotNull File getTableDestination(String columnPartitionValue)
      Description copied from interface: ImportTableWriterFactory
      Get a File representing the path where the table will be written.
      Parameters:
      columnPartitionValue - the column partition to find the destination for
      Returns:
      a file at the path the table will be written.

    • getLocalAppendableTable

      @NotNull public @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.appendable.local.LocalAppendableTable getLocalAppendableTable(String inputColumnPartitionValue, boolean forceAppend)
      Description copied from interface: ImportTableWriterFactory
      Returns the LocalAppendableTable for given column partition value.
      Specified by:
      getLocalAppendableTable in interface ImportTableWriterFactory
      Overrides:
      getLocalAppendableTable in class PreviewImportTableWriterFactoryBase<File>
      Parameters:
      inputColumnPartitionValue - the column partition to use. Some implementations allow nulls.
      forceAppend - When true, the LocalAppendableTable will be initialized to append to any existing data. When false, append/replace/fail behavior is implementation defined.
      Returns:
      Returned appropriate LocalAppendableTable for column partition value.

    • getRawTable

      protected Table getRawTable(@NotNull @NotNull String partitionValue, @NotNull @NotNull File location)
      Description copied from class: PreviewImportTableWriterFactoryBase
      Returns the raw (un-partitioned) Table for a single partition value, given the stored per-partition value that was accumulated during the import.
      Specified by:
      getRawTable in class PreviewImportTableWriterFactoryBase<File>
      Parameters:
      partitionValue - the computed column-partition value
      location - the per-partition resource for that partition
      Returns:
      the raw table for the partition, without the partitioning column populated