Package org.apache.flink.cdc.common.function

Interface HashFunction.HashContext

  • All Known Implementing Classes:
    DefaultHashContext
    Enclosing interface:
    HashFunction<T>
    @Internal
public static interface HashFunction.HashContext
    Runtime context for calculating an event hash code.

    • Method Detail

      • getSourceSubtaskIndex

        int getSourceSubtaskIndex()

      • getDownstreamParallelism

        int getDownstreamParallelism()