|
Move Method public before() : void from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to public before() : void from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Method public notifyTaskManagerOfAccumulatorUpdate() : void from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to public notifyTaskManagerOfAccumulatorUpdate() : void from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Method public flatMap(value String, out Collector<Integer>) : void from class org.apache.flink.test.accumulators.AccumulatorLiveITCase.NotifyingMapper to public flatMap(value String, out Collector<Integer>) : void from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase.NotifyingMapper |
From |
To |
|
Move Method private checkUserAccumulators(expected int, accumulatorMap Map<String,Accumulator<?,?>>) : boolean from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private checkUserAccumulators(expected int, accumulatorMap Map<String,Accumulator<?,?>>) : boolean from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Method private verifyResults() : void from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private verifyResults() : void from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Method public after() : void from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to public after() : void from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Attribute private jobManagerGateway : ActorGateway from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private jobManagerGateway : ActorGateway from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Attribute private system : ActorSystem from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private system : ActorSystem from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Attribute private TIMEOUT : FiniteDuration from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private TIMEOUT : FiniteDuration from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Attribute private jobID : JobID from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private jobID : JobID from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Attribute private taskManager : ActorRef from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private taskManager : ActorRef from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |
|
Move Attribute private jobGraph : JobGraph from class org.apache.flink.test.accumulators.AccumulatorLiveITCase to private jobGraph : JobGraph from class org.apache.flink.test.accumulators.LegacyAccumulatorLiveITCase |
From |
To |