Package org.apache.flink.cdc.common.function
-
Interface Summary Interface Description HashFunction<T> The hash function used to calculate the hash code from a given event.HashFunction.HashContext Runtime context for calculating an event hash code.HashFunctionProvider<T> Provider that providesHashFunctionto helpPrePartitionOperatorto shuffle event to designated subtask. -
Class Summary Class Description DefaultHashContext Default implementation ofHashFunction.HashContext.