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

Class Summary

Class	Description
ConstraintEnforcer	Processes RowData to enforce the following constraints: NOT NULL column constraint of a sink table CHAR(length)/@{code VARCHAR(length)}: trim string values to comply with the length defined in their corresponding types.
ConstraintEnforcer.Builder	Helper builder, so that the ConstraintEnforcer can be instantiated with only the NOT NULL constraint validation, only the CHAR/VARCHAR length validation, only the BINARY/VARBINARY length validation or combinations of them, or all of them.
ConstraintEnforcer.FieldInfo	Helper POJO to keep info about CHAR/VARCHAR/BINARY/VARBINARY fields, used to determine if trimming or padding is needed.
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.