b0f0f3722fac4726fba879736c7ee85993b392db
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 27
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 3 | ||
| Rename Method public setStreamStatus(status StreamStatus) : void renamed to public toggleStreamStatus(status StreamStatus) : void in class org.apache.flink.streaming.runtime.tasks.OperatorChain | From | To | |
| Rename Method public collect(element T) : void renamed to protected processAndCollect(element T) : void in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext | From | To | |
| Rename Method public emitWatermark(mark Watermark) : void renamed to protected processAndEmitWatermark(mark Watermark) : void in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext | From | To | |
| Pull Up Method | 7 | ||
| Pull Up Method public getCheckpointLock() : Object from class org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext to public getCheckpointLock() : Object from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Pull Up Method public collectWithTimestamp(element T, timestamp long) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext to public collectWithTimestamp(element T, timestamp long) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Pull Up Method public collectWithTimestamp(element T, timestamp long) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext to public collectWithTimestamp(element T, timestamp long) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Pull Up Method public emitWatermark(mark Watermark) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext to public emitWatermark(mark Watermark) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Pull Up Method public close() : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext to public close() : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Pull Up Method public collect(element T) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext to public collect(element T) : void from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Pull Up Method public getCheckpointLock() : Object from class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext to public getCheckpointLock() : Object from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type operatorChain : OperatorChain<?,TwoInputStreamOperator<IN1,IN2,?>> to streamStatusMaintainer : StreamStatusMaintainer in method public StreamTwoInputProcessor(inputGates1 Collection<InputGate>, inputGates2 Collection<InputGate>, inputSerializer1 TypeSerializer<IN1>, inputSerializer2 TypeSerializer<IN2>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, lock Object, ioManager IOManager, taskManagerConfig Configuration, streamStatusMaintainer StreamStatusMaintainer, streamOperator TwoInputStreamOperator<IN1,IN2,?>) in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Parameter Type operatorChain : OperatorChain<?,OneInputStreamOperator<IN,?>> to streamStatusMaintainer : StreamStatusMaintainer in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, lock Object, ioManager IOManager, taskManagerConfig Configuration, streamStatusMaintainer StreamStatusMaintainer, streamOperator OneInputStreamOperator<IN,?>) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Pull Up Attribute | 1 | ||
| Pull Up Attribute private timeService : ProcessingTimeService from class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext to protected timeService : ProcessingTimeService from class org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext | From | To | |
| Replace Variable With Attribute | 1 | ||
| Replace Variable With Attribute currentTime : long to lastRecordTime : long in method protected processAndCollect(element T) : void in class org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.api.operators.StreamSourceContexts.WatermarkContext from classes [org.apache.flink.streaming.api.operators.StreamSourceContexts.AutomaticWatermarkContext, org.apache.flink.streaming.api.operators.StreamSourceContexts.ManualWatermarkContext] | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute operatorChain : OperatorChain<?,OneInputStreamOperator<IN,?>> to streamStatusMaintainer : StreamStatusMaintainer in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Rename Attribute operatorChain : OperatorChain<?,TwoInputStreamOperator<IN1,IN2,?>> to streamStatusMaintainer : StreamStatusMaintainer in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type operatorChain : OperatorChain<?,TwoInputStreamOperator<IN1,IN2,?>> to streamStatusMaintainer : StreamStatusMaintainer in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type operatorChain : OperatorChain<?,OneInputStreamOperator<IN,?>> to streamStatusMaintainer : StreamStatusMaintainer in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter operatorChain : OperatorChain<?,OneInputStreamOperator<IN,?>> to streamStatusMaintainer : StreamStatusMaintainer in method public StreamInputProcessor(inputGates InputGate[], inputSerializer TypeSerializer<IN>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, lock Object, ioManager IOManager, taskManagerConfig Configuration, streamStatusMaintainer StreamStatusMaintainer, streamOperator OneInputStreamOperator<IN,?>) in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Rename Parameter operatorChain : OperatorChain<?,TwoInputStreamOperator<IN1,IN2,?>> to streamStatusMaintainer : StreamStatusMaintainer in method public StreamTwoInputProcessor(inputGates1 Collection<InputGate>, inputGates2 Collection<InputGate>, inputSerializer1 TypeSerializer<IN1>, inputSerializer2 TypeSerializer<IN2>, checkpointedTask StatefulTask, checkpointMode CheckpointingMode, lock Object, ioManager IOManager, taskManagerConfig Configuration, streamStatusMaintainer StreamStatusMaintainer, streamOperator TwoInputStreamOperator<IN1,IN2,?>) in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To |