28713a2962d97bf8809ad23d96d395d998a98be8
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move Method | 1 | ||
| Move Method private checkCollection(elements Collection<OUT>, viewedAs Class<OUT>) : void from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment to public checkCollection(elements Collection<OUT>, viewedAs Class<OUT>) : void from class org.apache.flink.streaming.api.functions.source.FromElementsFunction | From | To | |
| Rename Variable | 1 | ||
| Rename Variable value : T to next : T in method public run(ctx SourceContext<T>) : void in class org.apache.flink.streaming.api.functions.source.FromElementsFunction | From | To | |
| Change Return Type | 2 | ||
| Change Return Type Iterator[] to Iterator<T>[] in method public split(numPartitions int) : Iterator<T>[] in class org.apache.flink.streaming.api.StreamExecutionEnvironmentTest.DummySplittableIterator | From | To | |
| Change Return Type Object to T in method public next() : T in class org.apache.flink.streaming.api.StreamExecutionEnvironmentTest.DummySplittableIterator | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute elements : byte[] to elementsSerialized : byte[] in class org.apache.flink.streaming.api.functions.source.FromElementsFunction | From | To | |
| Extract Variable | 1 | ||
| Extract Variable first : OUT in method public fromCollection(data Collection<OUT>) : DataStreamSource<OUT> from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To |