Package org.apache.flink.cdc.debezium.table

Interface RowDataDebeziumDeserializeSchema.ValueValidator

All Superinterfaces:

Serializable

All Known Implementing Classes:

PostgresValueValidator

Enclosing class:

RowDataDebeziumDeserializeSchema

public static interface RowDataDebeziumDeserializeSchema.ValueValidator
extends Serializable

Custom validator to validate the row value.

Method Summary

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

Method Detail

validate

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

Throws:

Exception