d353895ba512a5e30fb08a25643fd93f085e8456
Files Diff
- Added: 9
- Removed: 1
- Renamed: 0
- Modified: 22
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type watchType : WatchType to watchType : FileMonitoringFunction.WatchType in method public readFileStream(filePath String, intervalMillis long, watchType FileMonitoringFunction.WatchType) : DataStream<String> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.functions.source.FileSourceFunction renamed to org.apache.flink.streaming.api.functions.source.InputFormatSource | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type fs : FileSourceFunction<T> to fs : InputFormatSource<T> in method private transformSource(source SourceTransformation<T>) : Collection<Integer> in class org.apache.flink.streaming.api.graph.StreamGraphGenerator | From | To | |
| Change Variable Type function : FileSourceFunction<OUT> to function : InputFormatSource<OUT> in method private createInput(inputFormat InputFormat<OUT,?>, typeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Extract Method | 3 | ||
| Extract Method private createAndReadBlockInfo() : BlockInfo extracted from public open(split FileInputSplit) : void in class org.apache.flink.api.common.io.BinaryInputFormat | From | To | |
| Extract Method private initReader(split FileInputSplit) : DataFileReader<E> extracted from public open(split FileInputSplit) : void in class org.apache.flink.api.java.io.AvroInputFormat | From | To | |
| Extract Method private initBuffers() : void extracted from public open(split FileInputSplit) : void in class org.apache.flink.api.common.io.DelimitedInputFormat | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type dataFileReader : FileReader<E> to dataFileReader : DataFileReader<E> in class org.apache.flink.api.java.io.AvroInputFormat | From | To |