cf88590e992b974284e01a3a35e8ad01fd47174e
Files Diff
- Added: 8
- Removed: 6
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 2 | ||
| Rename Variable results : List<Tuple2<Long,String>> to fileContent : List<Tuple2<Long,String>> in method private validateResults(folder File, expected List<Tuple2<Long,String>>) : void in class org.apache.flink.formats.sequencefile.SequenceStreamingFileSinkITCase | From | To | |
| Rename Variable results : List<Address> to fileContent : List<Tuple2<Long,String>> in method private validateResults(folder File, dataModel GenericData, expected List<T>) : void in class org.apache.flink.formats.parquet.avro.ParquetStreamingFileSinkITCase | From | To | |
| Move Source Folder | 1 | ||
| Move Source Folder flink-formats/flink-sequencefile to flink-formats/flink-sequence-file | From | To | |
| Extract Attribute | 1 | ||
| Extract Attribute private configuration : Configuration in class org.apache.flink.formats.sequencefile.SequenceStreamingFileSinkITCase | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.formats.sequencefile.SequenceFileSinkITCase renamed to org.apache.flink.formats.sequencefile.SequenceStreamingFileSinkITCase | From | To | |
| Move Class | 2 | ||
| Move Class org.apache.flink.formats.sequencefile.SequenceFileWriterFactory.SerializableHadoopConfiguration moved to org.apache.flink.formats.sequencefile.SerializableHadoopConfiguration | From | To | |
| Move Class org.apache.flink.test.util.FiniteTestSource moved to org.apache.flink.streaming.util.FiniteTestSource | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute data : List<Tuple2<Long,String>> to testData : List<Tuple2<Long,String>> in method public testWriteSequenceFile() : void in class org.apache.flink.formats.sequencefile.SequenceStreamingFileSinkITCase | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type results : List<Address> to fileContent : List<Tuple2<Long,String>> in method private validateResults(folder File, dataModel GenericData, expected List<T>) : void in class org.apache.flink.formats.parquet.avro.ParquetStreamingFileSinkITCase | From | To | |
| Extract Method | 1 | ||
| Extract Method private emitElementsAndWaitForCheckpoints(ctx SourceContext<T>, checkpointsToWaitFor int) : void extracted from public run(ctx SourceContext<T>) : void in class org.apache.flink.streaming.util.FiniteTestSource | From | To |