6886f638d70419e01ebdfc1cdbb6d834f3fb30b0
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 7
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Inline Method | 1 | ||
| Inline Method public hasTimestamp() : boolean inlined to public timestamp() : Long in class org.apache.flink.streaming.api.operators.StreamSink.SimpleContext | From | To | |
| Rename Variable | 1 | ||
| Rename Variable transformation : SingleOutputStreamOperator<Object> to streamSink : DataStreamSink<T> in method public writeToKafkaWithTimestamps(inStream DataStream<T>, topicId String, serializationSchema KeyedSerializationSchema<T>, producerConfig Properties, customPartitioner FlinkKafkaPartitioner<T>) : FlinkKafkaProducer010Configuration<T> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To | |
| Change Return Type | 2 | ||
| Change Return Type long to Long in method public timestamp() : Long in class org.apache.flink.streaming.api.operators.StreamSink.SimpleContext | From | To | |
| Change Return Type long to Long in method public timestamp() : Long in class org.apache.flink.streaming.api.functions.sink.SinkFunction.Context | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type transformation : SingleOutputStreamOperator<Object> to streamSink : DataStreamSink<T> in method public writeToKafkaWithTimestamps(inStream DataStream<T>, topicId String, serializationSchema KeyedSerializationSchema<T>, producerConfig Properties, customPartitioner FlinkKafkaPartitioner<T>) : FlinkKafkaProducer010Configuration<T> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer010 | From | To |