|
Rename Method public commitSpecificOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void renamed to public commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher |
From |
To |
|
Rename Method public commitSpecificOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void renamed to public commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher |
From |
To |
|
Rename Method public abstract commitSpecificOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void renamed to public abstract commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcher |
From |
To |
|
Rename Method public writeOffsets(offsetsToWrite Map<KafkaTopicPartition,Long>) : void renamed to public prepareAndCommitOffsets(internalOffsets Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Rename Method public commitSpecificOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void renamed to public commitInternalOffsetsToKafka(offsets Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest.TestFetcher |
From |
To |
|
Rename Method public getOffsets(partitions List<KafkaTopicPartition>) : Map<KafkaTopicPartition,Long> renamed to public getCommittedOffsets(partitions List<KafkaTopicPartition>) : Map<KafkaTopicPartition,Long> in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Rename Variable offset : long to lastProcessedOffset : Long in method public prepareAndCommitOffsets(internalOffsets Map<KafkaTopicPartition,Long>) : void in class org.apache.flink.streaming.connectors.kafka.internals.ZookeeperOffsetHandler |
From |
To |
|
Rename Variable v : int to val : int in method public flatMap(value Tuple2<Integer,Integer>, out Collector<Integer>) : void in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.readSequence.setParallelism.flatMap |
From |
To |
|
Rename Variable checkpointOffsets : HashMap<KafkaTopicPartition,Long> to offsets : HashMap<KafkaTopicPartition,Long> in method public notifyCheckpointComplete(checkpointId long) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase |
From |
To |
|
Rename Variable pendingCheckpoints : LinkedMap to pendingOffsetsToCommit : LinkedMap in method public testSnapshotState() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest |
From |
To |
|
Rename Variable offset : Long to zkOffset : Long in method public runFetchLoop() : void in class org.apache.flink.streaming.connectors.kafka.internals.Kafka08Fetcher |
From |
To |
|
Rename Variable currentOffsets : HashMap<KafkaTopicPartition,Long> to offsetsToCommit : HashMap<KafkaTopicPartition,Long> in method public run() : void in class org.apache.flink.streaming.connectors.kafka.internals.PeriodicOffsetCommitter |
From |
To |