31d3eaa7468a98334dd1c3fa049c9fad1c3b6ccf
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 11
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method private getFunctionForDataSource(dataStreamSource DataStreamSource<T>) : SourceFunction<T> renamed to private getFunctionFromDataSource(dataStreamSource DataStreamSource<T>) : SourceFunction<T> in class org.apache.flink.streaming.api.StreamExecutionEnvironmentTest | From | To | |
| Rename Method private getOperatorForDataStream(dataStream DataStream<?>) : StreamOperator<?> renamed to private getOperatorFromDataStream(dataStream DataStream<?>) : StreamOperator<?> in class org.apache.flink.streaming.api.StreamExecutionEnvironmentTest | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type runtimeCtx : StreamingRuntimeContext to runtimeCtx : RuntimeContext in method public run(sourceCtx SourceContext<Long>) : void in class org.apache.flink.test.recovery.ProcessFailureStreamingRecoveryITCase.SleepyDurableGenerateSequence | From | To |