| 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.
|
| SinkUpsertMaterializerV2 |
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.
|