Package org.apache.flink.table.runtime.operators.sink.constraint

Interface Constraint

  • All Superinterfaces:
    Serializable
    @Internal
public interface Constraint
extends Serializable
    Interface for constraints to be enforced on the input RowData.

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.apache.flink.table.data.RowData enforce​(org.apache.flink.table.data.RowData input)
      If a null value is returned, the input row is considered to be invalid and should be dropped.

    • Method Detail

      • enforce

        @Nullable
org.apache.flink.table.data.RowData enforce​(org.apache.flink.table.data.RowData input)
        If a null value is returned, the input row is considered to be invalid and should be dropped. This applies to all nested columns. If at any level a null value is returned, the incoming row is dropped from further processing.