|
Change Parameter Type futures : Collection<? extends Future<?>> to futures : Collection<? extends java.util.concurrent.CompletableFuture<?>> in method public createFuture(futures Collection<? extends java.util.concurrent.CompletableFuture<?>>) : ConjunctFuture<?> in class org.apache.flink.runtime.concurrent.FutureUtilsTest.WaitingFutureFactory |
From |
To |
|
Change Parameter Type slotFuture : Future<SimpleSlot> to slotFuture : CompletableFuture<SimpleSlot> in method public ExecutionAndSlot(executionAttempt Execution, slotFuture CompletableFuture<SimpleSlot>) in class org.apache.flink.runtime.executiongraph.ExecutionAndSlot |
From |
To |
|
Change Parameter Type futures : Collection<? extends Future<?>> to futures : Collection<? extends java.util.concurrent.CompletableFuture<?>> in method private WaitingConjunctFuture(futures Collection<? extends java.util.concurrent.CompletableFuture<?>>) in class org.apache.flink.runtime.concurrent.FutureUtils.WaitingConjunctFuture |
From |
To |
|
Change Parameter Type futures : Collection<? extends Future<?>> to futures : Collection<? extends java.util.concurrent.CompletableFuture<?>> in method public waitForAll(futures Collection<? extends java.util.concurrent.CompletableFuture<?>>) : ConjunctFuture<Void> in class org.apache.flink.runtime.concurrent.FutureUtils |
From |
To |
|
Change Parameter Type futures : Collection<? extends Future<? extends T>> to futures : Collection<? extends java.util.concurrent.CompletableFuture<? extends T>> in method public combineAll(futures Collection<? extends java.util.concurrent.CompletableFuture<? extends T>>) : ConjunctFuture<Collection<T>> in class org.apache.flink.runtime.concurrent.FutureUtils |
From |
To |
|
Change Parameter Type futures : Collection<? extends Future<?>> to futures : Collection<? extends java.util.concurrent.CompletableFuture<?>> in method public createFuture(futures Collection<? extends java.util.concurrent.CompletableFuture<?>>) : ConjunctFuture<?> in class org.apache.flink.runtime.concurrent.FutureUtilsTest.ConjunctFutureFactory |
From |
To |
|
Change Parameter Type futures : Collection<? extends Future<?>> to futures : Collection<? extends java.util.concurrent.CompletableFuture<?>> in method public createFuture(futures Collection<? extends java.util.concurrent.CompletableFuture<?>>) : ConjunctFuture<?> in class org.apache.flink.runtime.concurrent.FutureUtilsTest.FutureFactory |
From |
To |
|
Change Return Type Future<SimpleSlot> to CompletableFuture<SimpleSlot> in method public allocateSlotForExecution(slotProvider SlotProvider, queued boolean) : CompletableFuture<SimpleSlot> in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Return Type Future<Void> to CompletableFuture<Void> in method public cancelWithFuture() : CompletableFuture<Void> in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Return Type Future<JobStatus> to CompletableFuture<JobStatus> in method public getTerminationFuture() : CompletableFuture<JobStatus> in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public cancel() : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.executiongraph.ExecutionVertex |
From |
To |
|
Change Return Type Future<ExecutionState> to CompletableFuture<ExecutionState> in method public getTerminationFuture() : CompletableFuture<ExecutionState> in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Return Type Future<StackTraceSampleResponse> to CompletableFuture<StackTraceSampleResponse> in method public requestStackTraceSample(sampleId int, numSamples int, delayBetweenSamples Time, maxStrackTraceDepth int, timeout Time) : CompletableFuture<StackTraceSampleResponse> in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type futures : ArrayList<Future<?>> to futures : ArrayList<CompletableFuture<?>> in method private cancel(globalModVersionOfFailover long) : void in class org.apache.flink.runtime.executiongraph.failover.FailoverRegion |
From |
To |
|
Change Variable Type terminationFuture : Future<ExecutionState> to terminationFuture : CompletableFuture<ExecutionState> in method public onTaskFailure(taskExecution Execution, cause Throwable) : void in class org.apache.flink.runtime.executiongraph.failover.RestartIndividualStrategy |
From |
To |
|
Change Variable Type updatePartitionsResultFuture : Future<Acknowledge> to updatePartitionsResultFuture : CompletableFuture<Acknowledge> in method private sendUpdatePartitionInfoRpcCall(partitionInfos Iterable<PartitionInfo>) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type future2 : CompletableFuture<Object> to future2 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnFirst() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type inputStreamsFuture : Future<Collection<InputStream>> to inputStreamsFuture : CompletableFuture<Collection<InputStream>> in method public testConcurrentGetOperations() : void in class org.apache.flink.runtime.blob.BlobServerGetTest |
From |
To |
|
Change Variable Type incompleteFuture : FlinkCompletableFuture<SimpleSlot> to incompleteFuture : CompletableFuture<SimpleSlot> in method public testReleaseSlots() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphUtilsTest |
From |
To |
|
Change Variable Type future4 : CompletableFuture<Object> to future4 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnSuccessive() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future2 : CompletableFuture<Object> to future2 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnSuccessive() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future : FlinkCompletableFuture<StackTraceSampleResponse> to future : CompletableFuture<StackTraceSampleResponse> in method private mockExecutionVertexWithTimeout(executionId ExecutionAttemptID, state ExecutionState, scheduledExecutorService ScheduledExecutorService, timeout int) : ExecutionVertex in class org.apache.flink.runtime.webmonitor.StackTraceSampleCoordinatorTest |
From |
To |
|
Change Variable Type future4 : CompletableFuture<Object> to future4 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnFirst() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future1 : CompletableFuture<Object> to future1 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureCompletion() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type deleteFutures : List<Future<Void>> to deleteFutures : List<CompletableFuture<Void>> in method public testConcurrentDeleteOperations() : void in class org.apache.flink.runtime.blob.BlobServerDeleteTest |
From |
To |
|
Change Variable Type submitResultFuture : Future<Acknowledge> to submitResultFuture : CompletableFuture<Acknowledge> in method public deployToSlot(slot SimpleSlot) : void in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type waitFuture : Future<Void> to waitFuture : CompletableFuture<Void> in method public testConcurrentDeleteOperations() : void in class org.apache.flink.runtime.blob.BlobServerDeleteTest |
From |
To |
|
Change Variable Type futures : ArrayList<Future<?>> to futures : ArrayList<CompletableFuture<?>> in method public cancel() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type getOperations : List<Future<InputStream>> to getOperations : List<CompletableFuture<InputStream>> in method public testConcurrentGetOperations() : void in class org.apache.flink.runtime.blob.BlobServerGetTest |
From |
To |
|
Change Variable Type future : Future<SimpleSlot> to future : CompletableFuture<SimpleSlot> in method public allocateResourcesForAll(resourceProvider SlotProvider, queued boolean) : ExecutionAndSlot[] in class org.apache.flink.runtime.executiongraph.ExecutionJobVertex |
From |
To |
|
Change Variable Type future2 : CompletableFuture<Object> to future2 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureCompletion() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future3 : CompletableFuture<Double> to future3 : java.util.concurrent.CompletableFuture<Double> in method public testConjunctFutureValue() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type slotAllocationFuture : Future<SimpleSlot> to slotAllocationFuture : CompletableFuture<SimpleSlot> in method public scheduleForExecution(slotProvider SlotProvider, queued boolean) : boolean in class org.apache.flink.runtime.executiongraph.Execution |
From |
To |
|
Change Variable Type future1 : CompletableFuture<Object> to future1 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnFirst() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future3 : CompletableFuture<Object> to future3 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureCompletion() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future4 : CompletableFuture<Object> to future4 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureCompletion() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future3 : CompletableFuture<Object> to future3 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnSuccessive() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type future3 : CompletableFuture<Object> to future3 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnFirst() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type slotFutures : ArrayList<Future<SimpleSlot>> to slotFutures : ArrayList<CompletableFuture<SimpleSlot>> in method private scheduleEager(slotProvider SlotProvider, timeout Time) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type future1 : CompletableFuture<Object> to future1 : java.util.concurrent.CompletableFuture<Object> in method public testConjunctFutureFailureOnSuccessive() : void in class org.apache.flink.runtime.concurrent.FutureUtilsTest |
From |
To |
|
Change Variable Type futures : ArrayList<Future<?>> to futures : ArrayList<CompletableFuture<?>> in method public failGlobal(errorInfo ErrorInfo) : void in class org.apache.flink.runtime.executiongraph.ExecutionGraph |
From |
To |
|
Change Variable Type allFutures : ArrayList<Future<BlobKey>> to allFutures : ArrayList<CompletableFuture<BlobKey>> in method public testConcurrentPutOperations() : void in class org.apache.flink.runtime.blob.BlobServerPutTest |
From |
To |
|
Change Variable Type disposedSlotFuture : FlinkCompletableFuture<SimpleSlot> to disposedSlotFuture : CompletableFuture<SimpleSlot> in method public testReleaseSlots() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphUtilsTest |
From |
To |
|
Change Variable Type completeFuture : FlinkCompletableFuture<SimpleSlot> to completeFuture : CompletableFuture<SimpleSlot> in method public testReleaseSlots() : void in class org.apache.flink.runtime.executiongraph.ExecutionGraphUtilsTest |
From |
To |