Class AppendableColumnSinkFactory

java.lang.Object
com.illumon.iris.importers.csv.sink.AppendableColumnSinkFactory

public class AppendableColumnSinkFactory
extends Object
Factory class that provides factory methods for sink columns
  • Constructor Details

  • Method Details

    • makeSinkFactory

      public static io.deephaven.csv.sinks.SinkFactory makeSinkFactory​(@NotNull AppendableColumnSink[] columnSinks)
      Returns SinkFactory that creates an appropriate AppendableSink by column index.
      Parameters:
      columnSinks - array that holds all the columns in the same order as present in csv data file
      Returns:
      SinkFactory that creates the appropriate AppendableSink by column index
    • makeColumnSink

      public static BaseAppendableColumnSink makeColumnSink​(@NotNull com.fishlib.io.logger.Logger log, @NotNull String columnName, @Nullable ImporterColumnDefinition icdColDef, @Nullable ImportColumnDataTransformer columnDataTransformer, boolean isPartitionCol, boolean isColumnInSchema, boolean isColumnInSource, boolean schemaHasPartitionCol, boolean fromSplitFile)
      Returns a column sink of String data type or the data type defined in ImporterColumnDefinition if it is not null.