b18c66b5f7c59ccd1c3fe0d87cec11df16594e43
Files Diff
- Added: 10
- Removed: 4
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type initialOffset : long to waitOnEmptyFetchMillis : int in method public PersistentKafkaSource(zookeeperHost String, topicId String, deserializationSchema DeserializationSchema<OUT>, zookeeperSyncTimeMillis int, waitOnEmptyFetchMillis int) in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Change Parameter Type waitOnEmptyFetch : long to initialOffset : KafkaOffset in method public KafkaOnePartitionIterator(hostName String, port int, topic String, partition int, initialOffset KafkaOffset) in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator | From | To | |
| Move Method | 1 | ||
| Move Method private getLastOffset(consumer SimpleConsumer, topic String, partition int, whichTime long, clientName String) : long from class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaConsumerIterator to 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 | |
| Push Down Attribute | 1 | ||
| Push Down Attribute private partition : int from class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource to private partition : int from class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private partition : int from class org.apache.flink.streaming.connectors.kafka.KafkaSimpleConsumerExample to private partition : int from class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Move Attribute private offset : long from class org.apache.flink.streaming.connectors.kafka.KafkaSimpleConsumerExample to private offset : long from class org.apache.flink.streaming.connectors.kafka.api.simple.offset.GivenOffset | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.streaming.connectors.kafka.api.simple.offset.KafkaOffset from class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaConsumerIterator | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.connectors.kafka.api.simple.MessageWithOffset renamed to org.apache.flink.streaming.connectors.kafka.api.simple.MessageWithMetadata | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaConsumerIterator moved and renamed to org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicFactory.KafkaZKStringSerializer moved to org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicUtils.KafkaZKStringSerializer | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type msg : MessageWithOffset to msg : MessageWithMetadata in method public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Change Variable Type msg : MessageWithOffset to msg : MessageWithMetadata in method public run(collector Collector<OUT>) : void in class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource | From | To | |
| Change Return Type | 1 | ||
| Change Return Type MessageWithOffset to MessageWithMetadata in method public nextWithOffset() : MessageWithMetadata in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute waitOnEmptyFetch : long to initialOffset : KafkaOffset in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator | From | To | |
| Rename Attribute hostName : String to zookeeperServerAddress : String in class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaConsumerIterator from classes [org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator] | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type kafkaOffSet : OperatorState<Long> to kafkaOffSet : OperatorState<Map<Integer,KafkaOffset>> in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Change Attribute Type waitOnEmptyFetch : long to initialOffset : KafkaOffset in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter waitOnEmptyFetch : long to initialOffset : KafkaOffset in method public KafkaOnePartitionIterator(hostName String, port int, topic String, partition int, initialOffset KafkaOffset) in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaOnePartitionIterator | From | To | |
| Rename Parameter initialOffset : long to waitOnEmptyFetchMillis : int in method public PersistentKafkaSource(zookeeperHost String, topicId String, deserializationSchema DeserializationSchema<OUT>, zookeeperSyncTimeMillis int, waitOnEmptyFetchMillis int) in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Rename Parameter hostName : String to zookeeperServerAddress : String in method public SimpleKafkaSource(topic String, zookeeperServerAddress String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.kafka.api.simple.SimpleKafkaSource | From | To | |
| Rename Parameter host : String to zookeeperHost : String in method public PersistentKafkaSource(zookeeperHost String, topicId String, deserializationSchema DeserializationSchema<OUT>, zookeeperSyncTimeMillis int, waitOnEmptyFetchMillis int) in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To |