1f9c0cf8522481c1a1007d98d90b30baff5c18ca
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Return Type | 3 | ||
| Change Return Type Class<SerializationSchema<Row>> to SerializationSchema<Row> in method protected abstract getSerializationSchema() : SerializationSchema<Row> in class org.apache.flink.streaming.connectors.kafka.KafkaTableSinkTestBase | From | To | |
| Change Return Type Class<SerializationSchema<Row>> to SerializationSchema<Row> in method protected getSerializationSchema() : SerializationSchema<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka09JsonTableSinkTest | From | To | |
| Change Return Type Class<SerializationSchema<Row>> to SerializationSchema<Row> in method protected getSerializationSchema() : SerializationSchema<Row> in class org.apache.flink.streaming.connectors.kafka.Kafka08JsonTableSinkTest | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.connectors.kafka.AtLeastOnceProducerTest.TestingKafkaProducer moved and renamed to org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBaseTest.DummyFlinkKafkaProducer | From | To | |
| Move Class | 1 | ||
| Move Class org.apache.flink.streaming.connectors.kafka.AtLeastOnceProducerTest.MockProducer moved to org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBaseTest.MockProducer | From | To |