|
Rename Method public seekFetcherToInitialOffsets(partitions List<KafkaTopicPartitionLeader>, fetcher Fetcher) : void renamed to public getOffsets(partitions List<KafkaTopicPartition>, fetcher Fetcher) : Map<KafkaTopicPartition,Long> in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Rename Method public seekFetcherToInitialOffsets(partitions List<KafkaTopicPartitionLeader>, fetcher Fetcher) : void renamed to public getOffsets(partitions List<KafkaTopicPartition>, fetcher Fetcher) : Map<KafkaTopicPartition,Long> in class org.apache.flink.streaming.connectors.kafka.internals.OffsetHandler |
From |
To |
|
Rename Method public convertToPartitionInfo(partitionInfos List<KafkaTopicPartitionLeader>) : List<KafkaTopicPartition> renamed to public dropLeaderData(partitionInfos List<KafkaTopicPartitionLeader>) : List<KafkaTopicPartition> in class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition |
From |
To |
|
Change Parameter Type topicPartitionMap : Map<KafkaTopicPartition,?> to partitionsList : List<FetchPartition> in method public getTopics(partitionsList List<FetchPartition>) : List<String> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Change Parameter Type partitions : List<KafkaTopicPartitionLeader> to partitions : List<KafkaTopicPartition> in method public getOffsets(partitions List<KafkaTopicPartition>, fetcher Fetcher) : Map<KafkaTopicPartition,Long> in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Change Parameter Type partitions : List<KafkaTopicPartitionLeader> to partitions : List<KafkaTopicPartition> in method public toString(partitions List<KafkaTopicPartition>) : String in class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition |
From |
To |
|
Change Parameter Type partitions : List<KafkaTopicPartitionLeader> to partitions : List<KafkaTopicPartition> in method public getOffsets(partitions List<KafkaTopicPartition>, fetcher Fetcher) : Map<KafkaTopicPartition,Long> in class org.apache.flink.streaming.connectors.kafka.internals.OffsetHandler |
From |
To |
|
Rename Variable brokerInfo : Map.Entry<Node,List<FetchPartition>> to fp : FetchPartition in method public getTopics(partitionsList List<FetchPartition>) : List<String> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Rename Variable entry : Map.Entry<KafkaTopicPartitionLeader,Long> to partitionLeader : KafkaTopicPartitionLeader 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 consumers : ArrayList<SimpleConsumerThread<?>> to uniqueTopics : HashSet<String> in method public getTopics(partitionsList List<FetchPartition>) : List<String> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Rename Variable broker : Node to leader : Node in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, lastOffsets HashMap<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Rename Variable fetchBrokers : Map<Node,List<FetchPartition>> to leaderToPartitions : Map<Node,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 |
|
Rename Variable thread : SimpleConsumerThread<T> to fp : 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 topicPartitionWithLeader : KafkaTopicPartitionLeader to newPartitionsQueue : ClosableBlockingQueue<FetchPartition> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, lastOffsets HashMap<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Change Variable Type thread : SimpleConsumerThread<T> to fp : FetchPartition in method private findLeaderForPartitions(partitionsToAssign List<FetchPartition>) : Map<Node,List<FetchPartition>> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Change Variable Type topicPartitionWithLeader : KafkaTopicPartitionLeader to newPartitionsQueue : ClosableBlockingQueue<FetchPartition> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, lastOffsets HashMap<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Change Variable Type tp : KafkaTopicPartitionLeader to tp : KafkaTopicPartition in method public getOffsets(partitions List<KafkaTopicPartition>, fetcher Fetcher) : Map<KafkaTopicPartition,Long> in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Change Variable Type tp : KafkaTopicPartitionLeader to tp : KafkaTopicPartition in method protected commitOffsets(toCommit HashMap<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 |
From |
To |
|
Change Variable Type brokerInfo : Map.Entry<Node,List<FetchPartition>> to fp : FetchPartition in method public getTopics(partitionsList List<FetchPartition>) : List<String> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Change Variable Type entry : Map.Entry<KafkaTopicPartitionLeader,Long> to partitionLeader : KafkaTopicPartitionLeader in method private findLeaderForPartitions(partitionsToAssign List<FetchPartition>) : Map<Node,List<FetchPartition>> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |
|
Change Variable Type consumers : ArrayList<SimpleConsumerThread<?>> to uniqueTopics : HashSet<String> in method public getTopics(partitionsList List<FetchPartition>) : List<String> in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher |
From |
To |