Class EmptyRowDataKeySelector

  • All Implemented Interfaces:
    Serializable, 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>, RowDataKeySelector

    public class EmptyRowDataKeySelector
    extends Object
    implements RowDataKeySelector
    A utility class which key is always empty no matter what the input row is.
    See Also:
    Serialized Form
    • Constructor Detail

      • EmptyRowDataKeySelector

        public EmptyRowDataKeySelector()
    • Method Detail

      • getKey

        public org.apache.flink.table.data.RowData getKey​(org.apache.flink.table.data.RowData value)
                                                   throws Exception
        Specified by:
        getKey in interface org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,​org.apache.flink.table.data.RowData>
        Throws:
        Exception
      • getProducedType

        public 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>
        Specified by:
        getProducedType in interface RowDataKeySelector