b3186b6a109e4cd43216799e2f1c63ad8646bdab
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Pull Up Method | 1 | ||
| Pull Up Method public close() : void from class org.apache.flink.streaming.connectors.fs.StringWriter to public close() : void from class org.apache.flink.streaming.connectors.fs.StreamWriterBase | From | To | |
| Move Method | 2 | ||
| Move Method protected hflushOrSync(os FSDataOutputStream) : void from class org.apache.flink.streaming.connectors.fs.RollingSink to protected hflushOrSync(os FSDataOutputStream) : void from class org.apache.flink.streaming.connectors.fs.StreamWriterBase | From | To | |
| Move Method private reflectHflushOrSync(os FSDataOutputStream) : Method from class org.apache.flink.streaming.connectors.fs.RollingSink to private reflectHflushOrSync(os FSDataOutputStream) : Method from class org.apache.flink.streaming.connectors.fs.StreamWriterBase | From | To | |
| Change Return Type | 1 | ||
| Change Return Type void to long in method public flush() : long in class org.apache.flink.streaming.connectors.fs.Writer | From | To | |
| Move Attribute | 2 | ||
| Move Attribute private outStream : FSDataOutputStream from class org.apache.flink.streaming.connectors.fs.RollingSink to private outStream : FSDataOutputStream from class org.apache.flink.streaming.connectors.fs.StreamWriterBase | From | To | |
| Move Attribute private refHflushOrSync : Method from class org.apache.flink.streaming.connectors.fs.RollingSink to private refHflushOrSync : Method from class org.apache.flink.streaming.connectors.fs.StreamWriterBase | From | To | |
| Extract Class | 1 | ||
| Extract Class org.apache.flink.streaming.connectors.fs.StreamWriterBase from class org.apache.flink.streaming.connectors.fs.RollingSink | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.connectors.fs.StreamWriterBase from classes [org.apache.flink.streaming.connectors.fs.SequenceFileWriter, org.apache.flink.streaming.connectors.fs.StringWriter] | From | To |