Package | Description |
---|---|
org.apache.flink.table.runtime.operators.sink |
Class and 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.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.