25b6f22490550f0e1a6defef6148c35b69c009de
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 1 | ||
| Extract Method public setBlockSize(blockSize long) : void extracted from public configure(parameters Configuration) : void in class org.apache.flink.api.common.io.BinaryInputFormat | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter watchType : FileProcessingMode to monitoringMode : FileProcessingMode in method private createFileInput(inputFormat FileInputFormat<OUT>, typeInfo TypeInformation<OUT>, sourceName String, monitoringMode FileProcessingMode, pathFilter FilePathFilter, interval long) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To |