com.ververica.cdc.debezium.table

Interface RowDataDebeziumDeserializeSchema.ValueValidator

All Superinterfaces:

Serializable

Enclosing class:

RowDataDebeziumDeserializeSchema

public static interface RowDataDebeziumDeserializeSchema.ValueValidator
extends Serializable

Custom validator to validate the row value.

Method Summary

Modifier and Type	Method and 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