e8d1aa57a8246de0b78e799a02c08f4007fb3a92
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 4 | ||
Change Parameter Type transaction : FileTransaction to transaction : ContentTransaction in method protected abort(transaction ContentTransaction) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentDumpSinkFunction | From | To | |
Change Parameter Type transaction : FileTransaction to transaction : ContentTransaction in method protected commit(transaction ContentTransaction) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentDumpSinkFunction | From | To | |
Change Parameter Type transaction : FileTransaction to transaction : ContentTransaction in method protected preCommit(transaction ContentTransaction) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentDumpSinkFunction | From | To | |
Change Parameter Type transaction : FileTransaction to transaction : ContentTransaction in method protected invoke(transaction ContentTransaction, value String, context Context) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentDumpSinkFunction | From | To | |
Rename Variable | 1 | ||
Rename Variable file : File to name : String in method private assertExactlyOnce(expectedValues List<String>) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest | From | To | |
Change Return Type | 1 | ||
Change Return Type FileTransaction to ContentTransaction in method protected beginTransaction() : ContentTransaction in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentDumpSinkFunction | From | To | |
Rename Class | 2 | ||
Rename Class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.FileBasedSinkFunction renamed to org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentDumpSinkFunction | From | To | |
Rename Class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.FileTransaction renamed to org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentTransaction | From | To | |
Rename Attribute | 2 | ||
Rename Attribute writer : BufferedWriter to tmpContentWriter : ContentDump.ContentWriter in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentTransaction | From | To | |
Rename Attribute tmpFile : File to tmpContentWriter : ContentDump.ContentWriter in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentTransaction | From | To | |
Change Variable Type | 1 | ||
Change Variable Type file : File to name : String in method private assertExactlyOnce(expectedValues List<String>) : void in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest | From | To | |
Change Attribute Type | 5 | ||
Change Attribute Type sinkFunction : FileBasedSinkFunction to sinkFunction : ContentDumpSinkFunction in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest | From | To | |
Change Attribute Type tmpFile : File to tmpContentWriter : ContentDump.ContentWriter in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentTransaction | From | To | |
Change Attribute Type writer : BufferedWriter to tmpContentWriter : ContentDump.ContentWriter in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest.ContentTransaction | From | To | |
Change Attribute Type targetDirectory : File to targetDirectory : ContentDump in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest | From | To | |
Change Attribute Type tmpDirectory : File to tmpDirectory : ContentDump in class org.apache.flink.streaming.api.functions.sink.TwoPhaseCommitSinkFunctionTest | From | To |