Toggle navigation
Home
org.apache.flink.api.common.state.KeyGroupAssigner<K> to int
No. of Instances - 21
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Rename Variable
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
maxParallelism
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
maxParallelism
keyGroupAssigner
to
maxParallelism
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
keyGroupAssigner
to
numberOfKeyGroups
Add or Remove Method invocation
Preconditions.checkNotNull(keyGroupAssigner)
to
maxParallelism
keyGroupAssigner.getKeyGroupIndex(key)
to
maxParallelism
keyGroupAssigner.getNumberKeyGroups()
to
maxParallelism
KeyGroupRange.computeOperatorIndexForKeyGroup(maxParallelism,numberOfOutputChannels,maxParallelism)
to
KeyGroupRangeAssignment.assignKeyToParallelOperator(key,maxParallelism,numberOfOutputChannels)
Preconditions.checkNotNull(keyGroupAssigner)
to
maxParallelism
keyGroupAssigner.getKeyGroupIndex(newKey)
to
KeyGroupRangeAssignment.assignToKeyGroup(newKey,numberOfKeyGroups)