0ac1549ec58c1737a79e5770a171a8b14bed56dc
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 3 | ||
| Change Parameter Type lastOffsets : HashMap<KafkaTopicPartition,Long> to partitionState : HashMap<KafkaTopicPartition,KafkaPartitionState> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, partitionState HashMap<KafkaTopicPartition,KafkaPartitionState>) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher | From | To | |
| Change Parameter Type lastOffsets : HashMap<KafkaTopicPartition,Long> to lastOffsets : HashMap<KafkaTopicPartition,KafkaPartitionState> in method public run(sourceContext SourceFunction.SourceContext<T>, valueDeserializer KeyedDeserializationSchema<T>, lastOffsets HashMap<KafkaTopicPartition,KafkaPartitionState>) : void in class org.apache.flink.streaming.connectors.kafka.internals.Fetcher | From | To | |
| Change Parameter Type initialPartitionsToRead : Map<KafkaTopicPartition,Long> to initialPartitionsToRead : Map<KafkaTopicPartition,KafkaPartitionState> in method public LegacyFetcher(owner FlinkKafkaConsumer08<T>, initialPartitionsToRead Map<KafkaTopicPartition,KafkaPartitionState>, props Properties, taskName String, userCodeClassloader ClassLoader) in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher | From | To | |
| Rename Variable | 1 | ||
| Rename Variable offset : Map.Entry<KafkaTopicPartition,Long> to info : Map.Entry<KafkaTopicPartition,Long> in method public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer09 | From | To | |
| Pull Up Attribute | 1 | ||
| Pull Up Attribute public OFFSET_NOT_SET : long from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 to public OFFSET_NOT_SET : long from class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute offsetsState : HashMap<KafkaTopicPartition,Long> to partitionState : HashMap<KafkaTopicPartition,KafkaPartitionState> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Extract Variable | 1 | ||
| Extract Variable ktp : KafkaTopicPartition in method public testSnapshot() : void from class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTest | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type subscribedPartitionsWithOffsets : Map<KafkaTopicPartition,Long> to subscribedPartitionsWithOffsets : Map<KafkaTopicPartition,KafkaPartitionState> in method public open(parameters Configuration) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08 | From | To | |
| Change Variable Type partitionToRead : Map.Entry<KafkaTopicPartition,Long> to partitionToRead : Map.Entry<KafkaTopicPartition,KafkaPartitionState> in method public LegacyFetcher(owner FlinkKafkaConsumer08<T>, initialPartitionsToRead Map<KafkaTopicPartition,KafkaPartitionState>, props Properties, taskName String, userCodeClassloader ClassLoader) in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type offsetsState : HashMap<KafkaTopicPartition,Long> to partitionState : HashMap<KafkaTopicPartition,KafkaPartitionState> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter lastOffsets : HashMap<KafkaTopicPartition,Long> to partitionState : HashMap<KafkaTopicPartition,KafkaPartitionState> in method public run(sourceContext SourceFunction.SourceContext<T>, deserializer KeyedDeserializationSchema<T>, partitionState HashMap<KafkaTopicPartition,KafkaPartitionState>) : void in class org.apache.flink.streaming.connectors.kafka.internals.LegacyFetcher | From | To |