flink c0192ecad161ce85c07e448537027ac619ca2d14

c0192ecad161ce85c07e448537027ac619ca2d14

Files Diff

Added: 0
Removed: 0
Renamed: 0
Modified: 16

Link to commit

Dependency Action

Refactorings reported:

Refactoring Name	Occurences
Change Parameter Type	1
Change Parameter Type namespaceSerializer : TypeSerializer<N> to localKeyGroupRange : KeyGroupsList in method public HeapInternalTimerService(totalKeyGroups int, localKeyGroupRange KeyGroupsList, keyContext KeyContext, processingTimeService ProcessingTimeService) in class org.apache.flink.streaming.api.operators.HeapInternalTimerService	From	To
Rename Variable	1
Rename Variable service : HeapInternalTimerService<K,N> to timerService : HeapInternalTimerService<K,N> in method public getInternalTimerService(name String, keySerializer TypeSerializer<K>, namespaceSerializer TypeSerializer<N>, triggerable Triggerable<K,N>) : InternalTimerService<N> in class org.apache.flink.streaming.api.operators.AbstractStreamOperator	From	To
Change Variable Type	10
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testPointSessions() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testSnapshotAndRestore() : void in class org.apache.flink.streaming.api.operators.TimelyFlatMapTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testSessionWindowsWithContinuousEventTimeTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testReduceSessionWindows() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method private testSlidingEventTimeWindows(testHarness OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method private testTumblingEventTimeWindows(testHarness OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Tuple2<String,Integer>>) : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testSnapshotAndRestore() : void in class org.apache.flink.streaming.api.operators.co.TimelyCoFlatMapTest	From	To
Change Variable Type snapshot : StreamStateHandle to snapshot : OperatorStateHandles in method public testSessionWindowsWithCountTrigger() : void in class org.apache.flink.streaming.runtime.operators.windowing.WindowOperatorTest	From	To
Extract Variable	1
Extract Variable startIdx : int in method public HeapInternalTimerService(totalKeyGroups int, localKeyGroupRange KeyGroupsList, keyContext KeyContext, processingTimeService ProcessingTimeService) from class org.apache.flink.streaming.api.operators.HeapInternalTimerService	From	To
Change Attribute Type	1
Change Attribute Type triggerTarget : org.apache.flink.streaming.api.operators.Triggerable<K,N> to triggerTarget : Triggerable<K,N> in class org.apache.flink.streaming.api.operators.HeapInternalTimerService	From	To
Rename Parameter	1
Rename Parameter namespaceSerializer : TypeSerializer<N> to localKeyGroupRange : KeyGroupsList in method public HeapInternalTimerService(totalKeyGroups int, localKeyGroupRange KeyGroupsList, keyContext KeyContext, processingTimeService ProcessingTimeService) in class org.apache.flink.streaming.api.operators.HeapInternalTimerService	From	To

c0192ecad161ce85c07e448537027ac619ca2d14

Files Diff

Link to commit

Third party dependencies:

Refactorings reported: