Interface RowDataKeySelector

  • All Superinterfaces:
    org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>, Serializable
    All Known Implementing Classes:
    BinaryRowDataKeySelector, EmptyRowDataKeySelector, GenericRowDataKeySelector

    public interface RowDataKeySelector
    extends org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>
    RowDataKeySelector takes an RowData and extracts the deterministic key for the RowData.
    • Method Detail

      • getProducedType

        InternalTypeInfo<org.apache.flink.table.data.RowData> getProducedType()
        Specified by:
        getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.table.data.RowData>