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

Class ConstraintEnforcer.Builder

java.lang.Object

org.apache.flink.table.runtime.operators.sink.ConstraintEnforcer.Builder

Enclosing class:

ConstraintEnforcer

public static class ConstraintEnforcer.Builder
extends Object

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.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
void	addBinaryLengthConstraint(org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer, List<ConstraintEnforcer.FieldInfo> binaryFieldInfo, List<String> binaryFieldNames, String[] allFieldNames)
void	addCharLengthConstraint(org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer, List<ConstraintEnforcer.FieldInfo> charFieldInfo, List<String> charFieldNames, String[] allFieldNames)
void	addNotNullConstraint(org.apache.flink.table.api.config.ExecutionConfigOptions.NotNullEnforcer notNullEnforcer, int[] notNullFieldIndices, List<String> notNullFieldNames, String[] allFieldNames)
ConstraintEnforcer	build()	If neither of NOT NULL or CHAR/VARCHAR length or BINARY/VARBINARY enforcers are configured, null is returned.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

addNotNullConstraint

public void addNotNullConstraint(org.apache.flink.table.api.config.ExecutionConfigOptions.NotNullEnforcer notNullEnforcer,
                                 int[] notNullFieldIndices,
                                 List<String> notNullFieldNames,
                                 String[] allFieldNames)

addCharLengthConstraint

public void addCharLengthConstraint(org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer,
                                    List<ConstraintEnforcer.FieldInfo> charFieldInfo,
                                    List<String> charFieldNames,
                                    String[] allFieldNames)

addBinaryLengthConstraint

public void addBinaryLengthConstraint(org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer typeLengthEnforcer,
                                      List<ConstraintEnforcer.FieldInfo> binaryFieldInfo,
                                      List<String> binaryFieldNames,
                                      String[] allFieldNames)

build

public ConstraintEnforcer build()

If neither of NOT NULL or CHAR/VARCHAR length or BINARY/VARBINARY enforcers are configured, null is returned.