Class NullByteKeySelector<T>

  • Type Parameters:
    T - The type of the input element.
    All Implemented Interfaces:
    Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.java.functions.KeySelector<T,​Byte>

    @Internal
    public class NullByteKeySelector<T>
    extends Object
    implements org.apache.flink.api.java.functions.KeySelector<T,​Byte>
    Used as a dummy KeySelector to allow using keyed operators for non-keyed use cases. Essentially, it gives all incoming records the same key, which is a (byte) 0 value.
    See Also:
    Serialized Form
    • Constructor Detail

      • NullByteKeySelector

        public NullByteKeySelector()
    • Method Detail

      • getKey

        public Byte getKey​(T value)
                    throws Exception
        Specified by:
        getKey in interface org.apache.flink.api.java.functions.KeySelector<T,​Byte>
        Throws:
        Exception