0ab12d716171227f2a3956bf805e065434d6fbd9
Files Diff
- Added: 1
- Removed: 1
- Renamed: 0
- Modified: 32
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Variable Type | 2 | ||
| Change Variable Type tpe : Option<TypeInformation<?>> to tpe : Optional<TypeInformation<?>> in method private validateProctimeAttribute(proctimeAttribute Optional<String>) : Optional<String> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase | From | To | |
| Change Variable Type tpe : Option<TypeInformation<?>> to tpe : Optional<TypeInformation<?>> in method private validateRowtimeAttributeDescriptors(rowtimeAttributeDescriptors List<RowtimeAttributeDescriptor>) : List<RowtimeAttributeDescriptor> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSourceBase | From | To |