|
Rename Variable fpIter : Iterator<FetchPartition> to unassignedPartitionsIterator : Iterator<FetchPartition> in method private findLeaderForPartitions(partitionsToAssign List<FetchPartition>) : Map<Node,List<FetchPartition>> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Rename Variable fp : FetchPartition to unassignedPartition : FetchPartition in method private findLeaderForPartitions(partitionsToAssign List<FetchPartition>) : Map<Node,List<FetchPartition>> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Rename Variable partitionsToAssignInternal : List<FetchPartition> to unassignedPartitions : List<FetchPartition> in method private findLeaderForPartitions(partitionsToAssign List<FetchPartition>) : Map<Node,List<FetchPartition>> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |