Package io.deephaven.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(@NotNull 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 io.deephaven.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 io.deephaven.importers.csv.sink.AppendableSink

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

Methods inherited from interface io.deephaven.importers.csv.PartitionUpdatesObserver

onPartitionParserUpdate

Methods inherited from interface io.deephaven.importers.csv.RowUpdateObservable

registerRowUpdateObserver

Method Details

addColumnSink

void addColumnSink(@NotNull
 @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