|
Rename Variable futurePayload : CompletableFuture<O> to payload : O in method private requestHeartbeat(heartbeatMonitor HeartbeatMonitor<O>) : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerSenderImpl |
From |
To |
|
Rename Variable futureTimeout : CompletableFuture<ResourceID> to targetHeartbeatTimeoutFuture : CompletableFuture<ResourceID> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Rename Variable heartbeatManager2 : HeartbeatManagerSenderImpl<Object,Object> to heartbeatManagerSender : HeartbeatManagerSenderImpl<Integer,String> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Rename Variable resourceID2 : ResourceID to resourceIDSender : ResourceID in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Rename Variable heartbeatManager : HeartbeatManagerImpl<Object,Object> to heartbeatManagerTarget : HeartbeatManagerImpl<String,Integer> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Rename Variable heartbeatListener2 : TestingHeartbeatListener to heartbeatListenerSender : TestingHeartbeatListener<Integer,String> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Rename Variable heartbeatListener : HeartbeatListener<Object,Object> to heartbeatListenerTarget : TestingHeartbeatListener<String,Integer> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Rename Variable resourceID : ResourceID to resourceIdTarget : ResourceID in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Return Type CompletableFuture<Void> to Void in method public retrievePayload(resourceID ResourceID) : Void in class org.apache.flink.runtime.jobmaster.JobMaster.ResourceManagerHeartbeatListener |
From |
To |
|
Change Return Type CompletableFuture<AllocatedSlotReport> to AllocatedSlotReport in method public retrievePayload(resourceID ResourceID) : AllocatedSlotReport in class org.apache.flink.runtime.jobmaster.JobMaster.TaskManagerHeartbeatListener |
From |
To |
|
Change Return Type CompletableFuture<Integer> to Integer in method public retrievePayload(resourceID ResourceID) : Integer in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest.TargetDependentHeartbeatSender |
From |
To |
|
Change Return Type CompletableFuture<AccumulatorReport> to AccumulatorReport in method public retrievePayload(resourceID ResourceID) : AccumulatorReport in class org.apache.flink.runtime.taskexecutor.TaskExecutor.JobManagerHeartbeatListener |
From |
To |
|
Change Return Type CompletableFuture<O> to O in method public retrievePayload(resourceID ResourceID) : O in class org.apache.flink.runtime.heartbeat.HeartbeatListener |
From |
To |
|
Change Return Type CompletableFuture<Void> to Void in method public retrievePayload(resourceID ResourceID) : Void in class org.apache.flink.runtime.resourcemanager.ResourceManager.JobManagerHeartbeatListener |
From |
To |
|
Change Return Type CompletableFuture<Void> to Void in method public retrievePayload(resourceID ResourceID) : Void in class org.apache.flink.runtime.resourcemanager.ResourceManager.TaskManagerHeartbeatListener |
From |
To |
|
Change Return Type CompletableFuture<SlotReport> to SlotReport in method public retrievePayload(resourceID ResourceID) : SlotReport in class org.apache.flink.runtime.taskexecutor.TaskExecutor.ResourceManagerHeartbeatListener |
From |
To |
|
Change Variable Type heartbeatManager2 : HeartbeatManagerSenderImpl<Object,Object> to heartbeatManagerSender : HeartbeatManagerSenderImpl<Integer,String> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type heartbeatListener : TestingHeartbeatListener to heartbeatListener : SimpleTestingHeartbeatListener in method public testTargetUnmonitoring() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type heartbeatListener2 : TestingHeartbeatListener to heartbeatListenerSender : TestingHeartbeatListener<Integer,String> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type heartbeatManager : HeartbeatManagerImpl<Object,Object> to heartbeatManagerTarget : HeartbeatManagerImpl<String,Integer> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type heartbeatListener : HeartbeatListener<Object,Object> to heartbeatListenerTarget : TestingHeartbeatListener<String,Integer> in method public testHeartbeatCluster() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type heartbeatManager : HeartbeatManagerImpl<Object,Object> to heartbeatManager : HeartbeatManagerImpl<String,Integer> in method public testRegularHeartbeat() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type heartbeatListener : TestingHeartbeatListener to heartbeatListener : SimpleTestingHeartbeatListener in method public testHeartbeatTimeout() : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerTest |
From |
To |
|
Change Variable Type futurePayload : CompletableFuture<O> to payload : O in method private requestHeartbeat(heartbeatMonitor HeartbeatMonitor<O>) : void in class org.apache.flink.runtime.heartbeat.HeartbeatManagerSenderImpl |
From |
To |
|
Rename Parameter scheduledExecutor : ScheduledExecutor to mainThreadExecutor : ScheduledExecutor in method public createHeartbeatManagerSender(resourceId ResourceID, heartbeatListener HeartbeatListener<I,O>, mainThreadExecutor ScheduledExecutor, log Logger) : HeartbeatManager<I,O> in class org.apache.flink.runtime.heartbeat.HeartbeatServices |
From |
To |
|
Rename Parameter scheduledExecutor : ScheduledExecutor to mainThreadExecutor : ScheduledExecutor in method public createHeartbeatManager(resourceId ResourceID, heartbeatListener HeartbeatListener<I,O>, mainThreadExecutor ScheduledExecutor, log Logger) : HeartbeatManager<I,O> in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest.RecordingHeartbeatServices |
From |
To |
|
Rename Parameter scheduledExecutor : ScheduledExecutor to mainThreadExecutor : ScheduledExecutor in method public RecordingHeartbeatManagerImpl(heartbeatTimeoutIntervalMs long, ownResourceID ResourceID, heartbeatListener HeartbeatListener<I,O>, mainThreadExecutor ScheduledExecutor, log Logger, unmonitoredTargets BlockingQueue<ResourceID>, monitoredTargets BlockingQueue<ResourceID>) in class org.apache.flink.runtime.taskexecutor.TaskExecutorTest.RecordingHeartbeatManagerImpl |
From |
To |
|
Rename Parameter slotReport : SlotReport to payload : SlotReport in method public reportPayload(resourceID ResourceID, payload SlotReport) : void in class org.apache.flink.runtime.resourcemanager.ResourceManager.TaskManagerHeartbeatListener |
From |
To |
|
Rename Parameter scheduledExecutor : ScheduledExecutor to mainThreadExecutor : ScheduledExecutor in method package HeartbeatManagerSenderImpl(heartbeatPeriod long, heartbeatTimeout long, ownResourceID ResourceID, heartbeatListener HeartbeatListener<I,O>, mainThreadExecutor ScheduledExecutor, log Logger) in class org.apache.flink.runtime.heartbeat.HeartbeatManagerSenderImpl |
From |
To |
|
Rename Parameter scheduledExecutor : ScheduledExecutor to mainThreadExecutor : ScheduledExecutor in method public HeartbeatManagerImpl(heartbeatTimeoutIntervalMs long, ownResourceID ResourceID, heartbeatListener HeartbeatListener<I,O>, mainThreadExecutor ScheduledExecutor, log Logger) in class org.apache.flink.runtime.heartbeat.HeartbeatManagerImpl |
From |
To |
|
Rename Parameter scheduledExecutor : ScheduledExecutor to mainThreadExecutor : ScheduledExecutor in method public createHeartbeatManager(resourceId ResourceID, heartbeatListener HeartbeatListener<I,O>, mainThreadExecutor ScheduledExecutor, log Logger) : HeartbeatManager<I,O> in class org.apache.flink.runtime.heartbeat.HeartbeatServices |
From |
To |