92b1e471d4762545637817c74f9396765984b39a
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 34
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Method | 4 | ||
Rename Method protected closeOperator() : void renamed to private closeAllOperators() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
Rename Method public registerInputOutput() : void renamed to public init() : void in class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask | From | To | |
Rename Method protected openOperator() : void renamed to private openAllOperators() : void in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
Rename Method public registerInputOutput() : void renamed to public init() : void in class org.apache.flink.streaming.runtime.tasks.OneInputStreamTask | From | To | |
Pull Up Method | 3 | ||
Pull Up Method public invoke() : void from class org.apache.flink.streaming.runtime.tasks.SourceStreamTask to public invoke() : void from class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
Pull Up Method public invoke() : void from class org.apache.flink.streaming.runtime.tasks.TwoInputStreamTask to public invoke() : void from class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
Pull Up Method public invoke() : void from class org.apache.flink.streaming.runtime.tasks.OneInputStreamTask to public invoke() : void from class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
Change Parameter Type | 1 | ||
Change Parameter Type recordWriter : RecordWriter<?> to recordWriter : StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>> in method public RecordWriterOutput(recordWriter StreamRecordWriter<SerializationDelegate<StreamRecord<OUT>>>, outSerializer TypeSerializer<OUT>, enableWatermarkMultiplexing boolean) in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
Change Return Type | 2 | ||
Change Return Type Map<String,StreamOperatorState> to Map<String,StreamOperatorState<?,?>> in method public getOperatorStates() : Map<String,StreamOperatorState<?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
Change Return Type StreamOperatorState to StreamOperatorState<?,?> in method public createRawState(partitioned boolean) : StreamOperatorState<?,?> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
Move Attribute | 4 | ||
Move Attribute private shouldWait : boolean from class org.apache.flink.streaming.runtime.tasks.StreamIterationHead to private shouldWait : boolean from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher | From | To | |
Move Attribute private shouldWait : boolean from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail to private shouldWait : boolean from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher | From | To | |
Move Attribute private iterationWaitTime : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationHead to private iterationWaitTime : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher | From | To | |
Move Attribute private iterationWaitTime : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail to private iterationWaitTime : long from class org.apache.flink.streaming.runtime.tasks.StreamIterationTail.RecordPusher | From | To | |
Merge Parameter | 1 | ||
Merge Parameter [name : String, userCodeClassLoader : ClassLoader] to env : Environment in method public StreamingRuntimeContext(env Environment, executionConfig ExecutionConfig, statePartitioner KeySelector<?,?>, provider StateHandleProvider<?>, accumulatorMap Map<String,Accumulator<?,?>>) in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
Replace Variable With Attribute | 1 | ||
Replace Variable With Attribute service : ScheduledExecutorService to scheduleExecutor : ScheduledExecutorService in method public AutomaticWatermarkContext(lockingObjectParam Object, outputParam Output<StreamRecord<T>>, executionConfig ExecutionConfig) in class org.apache.flink.streaming.api.operators.StreamSource.AutomaticWatermarkContext | From | To | |
Change Variable Type | 5 | ||
Change Variable Type operatorStates : Map<String,StreamOperatorState> to operatorStates : Map<String,StreamOperatorState<?,?>> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
Change Variable Type states : Map<String,StreamOperatorState> to states : Map<String,StreamOperatorState<?,?>> in method public close() : void in class org.apache.flink.streaming.api.state.StatefulOperatorTest.StatefulMapper2 | From | To | |
Change Variable Type state : StreamOperatorState to state : StreamOperatorState<?,?> in method public getState(name String, partitioned boolean) : StreamOperatorState<?,?> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
Change Variable Type states : Map<String,StreamOperatorState> to states : Map<String,StreamOperatorState<?,?>> in method public close() : void in class org.apache.flink.streaming.api.state.StatefulOperatorTest.StatefulMapper | From | To | |
Change Variable Type state : Entry<String,StreamOperatorState> to state : Entry<String,StreamOperatorState<?,?>> in method public getStateSnapshotFromFunction(checkpointId long, timestamp long) : Tuple2<StateHandle<Serializable>,Map<String,OperatorStateHandle>> in class org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator | From | To | |
Inline Variable | 1 | ||
Inline Variable env : Environment in method public createRuntimeContext(conf StreamConfig, accumulatorMap Map<String,Accumulator<?,?>>) : StreamingRuntimeContext from class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
Change Attribute Type | 4 | ||
Change Attribute Type recordWriter : RecordWriter<SerializationDelegate<Object>> to recordWriter : StreamRecordWriter<SerializationDelegate<Object>> in class org.apache.flink.streaming.runtime.io.RecordWriterOutput | From | To | |
Change Attribute Type partitionedStates : List<PartitionedStreamOperatorState> to partitionedStates : List<PartitionedStreamOperatorState<?,?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
Change Attribute Type states : Map<String,StreamOperatorState> to states : Map<String,StreamOperatorState<?,?>> in class org.apache.flink.streaming.runtime.tasks.StreamingRuntimeContext | From | To | |
Change Attribute Type taskThread : Thread to taskThread : TaskThread in class org.apache.flink.streaming.runtime.tasks.StreamTaskTestHarness | From | To |