Package org.apache.flink.cdc.connectors.postgres.table

Class PostgresValueValidator

java.lang.Object

org.apache.flink.cdc.connectors.postgres.table.PostgresValueValidator

All Implemented Interfaces:

Serializable, RowDataDebeziumDeserializeSchema.ValueValidator

public final class PostgresValueValidator
extends Object
implements RowDataDebeziumDeserializeSchema.ValueValidator

The RowDataDebeziumDeserializeSchema.ValueValidator for Postgres connector.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
PostgresValueValidator(String schema, String table)

Method Summary

Modifier and Type	Method	Description
void	validate(org.apache.flink.table.data.RowData rowData, org.apache.flink.types.RowKind rowKind)

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresValueValidator

public PostgresValueValidator(String schema,
                              String table)

Method Detail

validate

public void validate(org.apache.flink.table.data.RowData rowData,
                     org.apache.flink.types.RowKind rowKind)
              throws Exception

Specified by:

validate in interface RowDataDebeziumDeserializeSchema.ValueValidator

Throws:

Exception