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.
|
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.