Class | Description |
---|---|
OutputConversionOperator |
Operator that converts to external data structures and unwraps atomic records if necessary.
|
SinkNotNullEnforcer |
Checks writing null values into NOT NULL columns.
|
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.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.