Class DefaultHashContext
- java.lang.Object
-
- org.apache.flink.cdc.common.function.DefaultHashContext
-
- All Implemented Interfaces:
HashFunction.HashContext
@Internal public final class DefaultHashContext extends Object implements HashFunction.HashContext
Default implementation ofHashFunction.HashContext.
-
-
Constructor Summary
Constructors Constructor Description DefaultHashContext(int sourceSubtaskIndex, int downstreamParallelism)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description intgetDownstreamParallelism()intgetSourceSubtaskIndex()
-
-
-
Method Detail
-
getSourceSubtaskIndex
public int getSourceSubtaskIndex()
- Specified by:
getSourceSubtaskIndexin interfaceHashFunction.HashContext
-
getDownstreamParallelism
public int getDownstreamParallelism()
- Specified by:
getDownstreamParallelismin interfaceHashFunction.HashContext
-
-