fe0eb602d2e908d116d71018bb141e5c748c780b
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 3
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.api.functions.source.InputFormatSource renamed to org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction | From | To | |
| Change Variable Type | 2 | ||
| Change Variable Type fs : InputFormatSource<T> to fs : InputFormatSourceFunction<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 : InputFormatSource<OUT> to function : InputFormatSourceFunction<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 |