Package org.apache.flink.table.runtime.operators.sink

Class Summary

Class	Description
OutputConversionOperator	Operator that converts to external data structures and unwraps atomic records if necessary.
RowKindSetter	An operator that sets the row kind of the incoming records to a specific row kind.
SinkOperator	A StreamOperator for executing SinkFunctions.
SinkUpsertMaterializer	An operator that maintains incoming records in state corresponding to the upsert keys and generates an upsert view for the downstream operator.
StreamRecordTimestampInserter	Operator which sets the timestamp on the StreamRecord from the corresponding column of each row.