354922bed7ffe5482513ac53b5ef56bfbca8bd9a
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 10
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Merge Attribute | 2 | ||
| Merge Attribute [connectTimeoutMs : int, bufferSize : int] to consumerConfig : ConsumerConfig in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Merge Attribute [waitOnEmptyFetchMillis : int, connectTimeoutMs : int, bufferSize : int] to consumerConfig : ConsumerConfig in class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type connectTimeoutMs : int to consumerConfig : ConsumerConfig in method public KafkaSinglePartitionIterator(topic String, partition int, initialOffset KafkaOffset, kafkaTopicUtils KafkaTopicUtils, consumerConfig ConsumerConfig) in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.api.java.typeutils.runtime.TestInputView renamed to org.apache.flink.api.java.typeutils.runtime.ByteArrayInputView | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter connectTimeoutMs : int to consumerConfig : ConsumerConfig in method public KafkaSinglePartitionIterator(topic String, partition int, initialOffset KafkaOffset, kafkaTopicUtils KafkaTopicUtils, consumerConfig ConsumerConfig) in class org.apache.flink.streaming.connectors.kafka.api.simple.iterator.KafkaSinglePartitionIterator | From | To |