Package com.illumon.iris.importers.csv.sink

Interface ColumnSinkHolder<DATA_TYPE,TARRAY>

Type Parameters:

DATA_TYPE - The column data type

TARRAY - The stored values array data type (for example Integer DataType column would have int[] array data type) * on occasion this may be different for example AppendableBooleanAsByteColumnSink

All Superinterfaces:

AppendableColumnSink<DATA_TYPE,TARRAY>, AppendableSink<DATA_TYPE,TARRAY>, PartitionUpdatesObserver, RowUpdateObservable, io.deephaven.csv.sinks.Sink<TARRAY>

All Known Implementing Classes:

AppendableColumnSinkHolder

public interface ColumnSinkHolder<DATA_TYPE,TARRAY>
extends AppendableColumnSink<DATA_TYPE,TARRAY>

The dhc parser associates one sink and one parser for each source column. However, a single source column can be associated with multiple columns in the TableDefinition. This interface defines the attributes that allow a single AppendableColumnSink to handle this scenario.

Method Summary

Modifier and Type	Method	Description
void	addColumnSink(BaseAppendableColumnSink<?,?> columnSink)	Adds the column sink to the holder list of column sinks that are source by SinkHolder's Source column
List<BaseAppendableColumnSink<?,?>>	getColumnSinks()	Returns the list of ColumnSinks that are part of this SinkHolder.

Methods inherited from interface com.illumon.iris.importers.csv.sink.AppendableColumnSink

add, addAppendableColumn, addBooleans, addBytes, addChars, addDoubles, addFloats, addInts, addLongs, addShorts, evict, getColumnDataTransformer, getColumnName, getCsvSourceColumnName, isColumnInSchema, isColumnInSource, isColumnOnlyInSchema, isConstantColumn, isNotConsideredPartSourceFileMapping, isPartitionCol, publishRowUpdate, supportsTransformations

Methods inherited from interface com.illumon.iris.importers.csv.sink.AppendableSink

getConstantValue, getCustomSinkDataProcessor, getUnderlying, isCustomSetterColumn, nullFlagsToValues, publishToCustomSetter, updateCustomSetterData, updateNonSourceColRowChunk, updateRowChunk, validateForProcessingErrors, write, writeToLocal

Methods inherited from interface com.illumon.iris.importers.csv.PartitionUpdatesObserver

onPartitionParserUpdate

Methods inherited from interface com.illumon.iris.importers.csv.RowUpdateObservable

registerRowUpdateObserver

Method Details

addColumnSink

void addColumnSink(@NotNull
 BaseAppendableColumnSink<?,?> columnSink)

Adds the column sink to the holder list of column sinks that are source by SinkHolder's Source column

Parameters:

columnSink - columnSink that is sourced by SinkHolder's Source column

getColumnSinks

List<BaseAppendableColumnSink<?,?>> getColumnSinks()

Returns the list of ColumnSinks that are part of this SinkHolder.

Returns:

list of ColumnSinks that are part of this SinkHolder