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 Summary
Constructors Constructor Description AppendableColumnSinkFactory()
-
Method Summary
Modifier and Type Method Description static BaseAppendableColumnSink
makeColumnSink(com.fishlib.io.logger.Logger log, String columnName, ImporterColumnDefinition icdColDef, 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.static io.deephaven.csv.sinks.SinkFactory
makeSinkFactory(AppendableColumnSink[] columnSinks)
Returns SinkFactory that creates an appropriate AppendableSink by column index.
-
Constructor Details
-
AppendableColumnSinkFactory
public AppendableColumnSinkFactory()
-
-
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.
-