dcf86c27b91170f99c4d575950c72db8d14617dc
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type deserializationSchema : DeserializationSchema<T> to deserializationSchema : KeyedDeserializationSchema<T> in method protected abstract getConsumer(topics List<String>, deserializationSchema KeyedDeserializationSchema<T>, props Properties) : FlinkKafkaConsumer<T> in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Change Parameter Type deserializationSchema : DeserializationSchema<T> to deserializationSchema : KeyedDeserializationSchema<T> in method protected getConsumer(topics List<String>, deserializationSchema KeyedDeserializationSchema<T>, props Properties) : FlinkKafkaConsumer<T> in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method | 2 | ||
| Extract Method protected getConsumer(topics List<String>, deserializationSchema DeserializationSchema<T>, props Properties) : FlinkKafkaConsumer<T> extracted from protected getConsumer(topic String, deserializationSchema DeserializationSchema<T>, props Properties) : FlinkKafkaConsumer<T> in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To | |
| Extract Method protected getConsumer(topic String, deserializationSchema KeyedDeserializationSchema<T>, props Properties) : FlinkKafkaConsumer<T> extracted from protected getConsumer(topic String, deserializationSchema DeserializationSchema<T>, props Properties) : FlinkKafkaConsumer<T> in class org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase | From | To |