Package io.deephaven.importers.csv

Interface RowUpdateObservable

All Known Subinterfaces:

AppendableColumnSink<DATA_TYPE,TARRAY>, AppendableSink<TYPE,TARRAY>, ColumnSinkHolder<DATA_TYPE,TARRAY>

All Known Implementing Classes:

AppendableColumnSinkHolder, AppendableInstantArrayColumnSink, AppendableInstantColumnSink, BaseAppendableColumnSink

public interface RowUpdateObservable

This is an Observable interface that allows RowUpdateObserver to register. Observers will be notified of size and end index of the current rows chunk.

Schema only columns such as Constant Column or Single Partition columns rely on these updates to move forward with their processing. Source file column sinks are the RowUpdateObservable's for them.

To normalize flow of row update to schema only columns, AppendableTableWrapper which has knowledge of both schema only columns, Partition Column, and source file columns chooses one source file column as the designated RowUpdateObservable and registers itself as a RowUpdateObserver, receives the updates and notifies the schema only columns

Method Summary

Modifier and Type	Method	Description
void	registerRowUpdateObserver(RowUpdateObserver observer)	Registers the provided observer and publishes the row updates to it

Method Details

registerRowUpdateObserver

void registerRowUpdateObserver(RowUpdateObserver observer)

Registers the provided observer and publishes the row updates to it

Parameters:

observer - The observer that will process the updates