7d2c269bc4214aef94be1f15a35ce859a16906fa
Files Diff
- Added: 0
- Removed: 37
- Renamed: 0
- Modified: 8
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Attribute Type | 2 | ||
Change Attribute Type serializationSchema : Optional<SerializationSchema<Row>> to serializationSchema : SerializationSchema<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase | From | To | |
Change Attribute Type schema : Optional<TableSchema> to schema : TableSchema in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkBase | From | To |