ea710204e4d1ac6ac6d3e6ce31215aa0b8ff50b1
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 1 | ||
| Rename Variable numOfMessagesToReceive : int to numOfMessagesToBeCorrect : int in method public brokerFailureTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute partitions : Map<Integer,KafkaOffset> to partitionOffsets : Map<Integer,KafkaOffset> in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Rename Attribute kafkaOffSet : OperatorState<Map<Integer,KafkaOffset>> to kafkaOffSetOperatorState : OperatorState<Map<Integer,KafkaOffset>> in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Extract Variable | 1 | ||
| Extract Variable errorCode : int in method protected getLastOffset(consumer SimpleConsumer, topic String, partition int, whichTime long, clientName String) : long from class org.apache.flink.streaming.connectors.kafka.api.simple.offset.KafkaOffset | From | To | |
| Extract Method | 1 | ||
| Extract Method private getPartitionMetadata() : PartitionMetadata extracted from public initialize() : void in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter a_partition : int to partition : int in method private findLeader(addresses List<String>, topic String, partition int) : PartitionMetadata in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Parameter a_topic : String to topic : String in method private findLeader(addresses List<String>, topic String, partition int) : PartitionMetadata in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Parameter a_oldLeader : Broker to oldLeader : Broker in method private findNewLeader(oldLeader Broker, topic String, a_partition int) : Broker in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Parameter a_topic : String to topic : String in method private findNewLeader(oldLeader Broker, topic String, a_partition int) : Broker in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To |