1c3b67edd007d6d3727f1786eb0a99a0ee3a64c9
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 1 | ||
| Rename Method private addFileSource(inputFormat InputFormat<String,?>, typeInfo TypeInformation<String>) : DataStreamSource<String> renamed to private createInput(inputFormat InputFormat<OUT,?>, typeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Change Parameter Type | 4 | ||
| Change Parameter Type inputFormat : InputFormat<String,?> to inputFormat : InputFormat<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 | |
| Change Parameter Type inputFormat : InputFormat<String,?> to inputFormat : InputFormat<?,?> in method public setInputFormat(vertexID Integer, inputFormat InputFormat<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamGraph | From | To | |
| Change Parameter Type typeInfo : TypeInformation<String> to typeInfo : TypeInformation<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 | |
| Change Parameter Type inputFormat : InputFormat<String,?> to inputFormat : InputFormat<?,?> in method public setInputFormat(inputFormat InputFormat<?,?>) : void in class org.apache.flink.streaming.api.graph.StreamNode | From | To | |
| Rename Variable | 3 | ||
| Rename Variable outTypeInfo : TypeInformation<OUT> to typeInfo : TypeInformation<OUT> in method public addSource(function SourceFunction<OUT>, sourceName String) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Rename Variable outTypeInfo : TypeInformation<OUT> to typeInfo : TypeInformation<OUT> in method public fromCollection(data Collection<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Rename Variable outTypeInfo : TypeInformation<OUT> to typeInfo : TypeInformation<OUT> in method public fromElements(data OUT...) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Change Return Type | 3 | ||
| Change Return Type InputFormat<String,?> to InputFormat<?,?> in method public getInputFormat() : InputFormat<?,?> in class org.apache.flink.streaming.api.graph.StreamNode | From | To | |
| Change Return Type String to OUT in method public next() : OUT in class org.apache.flink.streaming.api.functions.source.FileSourceFunction | From | To | |
| Change Return Type DataStreamSource<String> to DataStreamSource<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 | |
| Change Variable Type | 2 | ||
| Change Variable Type result : String to result : OUT in method public next() : OUT in class org.apache.flink.streaming.api.functions.source.FileSourceFunction | From | To | |
| Change Variable Type function : FileSourceFunction to function : FileSourceFunction<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 | |
| Change Attribute Type | 5 | ||
| Change Attribute Type serializer : TypeSerializer<String> to serializer : TypeSerializer<OUT> in class org.apache.flink.streaming.api.functions.source.FileSourceFunction | From | To | |
| Change Attribute Type typeInfo : TypeInformation<String> to typeInfo : TypeInformation<OUT> in class org.apache.flink.streaming.api.functions.source.FileSourceFunction | From | To | |
| Change Attribute Type inputFormat : InputFormat<String,?> to inputFormat : InputFormat<?,?> in class org.apache.flink.streaming.api.graph.StreamNode | From | To | |
| Change Attribute Type format : InputFormat<String,InputSplit> to format : InputFormat<OUT,InputSplit> in class org.apache.flink.streaming.api.functions.source.FileSourceFunction | From | To | |
| Change Attribute Type nextElement : String to nextElement : OUT in class org.apache.flink.streaming.api.functions.source.FileSourceFunction | From | To |