Toggle navigation
Home
org.apache.kafka.common.TopicPartition to org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartitionLeader
No. of Instances - 30
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
allNewPartitions.remove(p.partition())
to
allNewPartitions.remove(p)
contains(partitions,parts.get(0).partition())
to
contains(inPartitions,parts.get(0).getTopicPartition().getPartition())
tp.topic()
to
tp.getTopicPartition().getTopic()
tp.partition()
to
tp.getTopicPartition().getPartition()
tp.partition()
to
tp.getTopicPartition().getPartition()
tp
to
tp.getTopicPartition()
allInitialPartitions.remove(p.partition())
to
allInitialPartitions.remove(p)
allNewPartitions.remove(p.partition())
to
allNewPartitions.remove(p)
allPartitions.remove(p.partition())
to
allPartitions.remove(p)
assignPartitions(this.partitions,this.topic,numConsumers,thisComsumerIndex)
to
assignPartitions(this.partitionInfos,numConsumers,thisConsumerIndex)
allPartitions.remove(p.partition())
to
allPartitions.remove(p)
allNewPartitions.remove(p.partition())
to
allNewPartitions.remove(p)
allInitialPartitions.remove(p.partition())
to
allInitialPartitions.remove(p)
allInitialPartitions.remove(p.partition())
to
allInitialPartitions.remove(p)
Rename Variable
tp
to
p
tp
to
p