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

Class ConstraintEnforcerExecutor

java.lang.Object

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

All Implemented Interfaces:

Serializable

@Internal
public class ConstraintEnforcerExecutor
extends Object
implements Serializable

Logic extracted from ConstraintEnforcer in order to use it outside of TableStreamOperator.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
static Optional<ConstraintEnforcerExecutor>	create(org.apache.flink.table.types.logical.RowType physicalType, org.apache.flink.table.api.config.ExecutionConfigOptions.NotNullEnforcer notNullEnforcer, org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer, org.apache.flink.table.api.config.ExecutionConfigOptions.NestedEnforcer nestedConstraints)
org.apache.flink.table.data.RowData	enforce(org.apache.flink.table.data.RowData row)
Constraint[]	getConstraints()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getConstraints

public Constraint[] getConstraints()

create

public static Optional<ConstraintEnforcerExecutor> create(org.apache.flink.table.types.logical.RowType physicalType,
                                                          org.apache.flink.table.api.config.ExecutionConfigOptions.NotNullEnforcer notNullEnforcer,
                                                          org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer,
                                                          org.apache.flink.table.api.config.ExecutionConfigOptions.NestedEnforcer nestedConstraints)

enforce

@Nullable
public org.apache.flink.table.data.RowData enforce(org.apache.flink.table.data.RowData row)