- 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