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

Interface Summary

Interface	Description
Constraint	Interface for constraints to be enforced on the input RowData.

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.
ConstraintEnforcerExecutor	Logic extracted from ConstraintEnforcer in order to use it outside of TableStreamOperator.

Exception Summary

Exception	Description
EnforcerException	Exception thrown when a constraint is violated.