Toggle navigation
Home
java.util.concurrent.Future to java.util.concurrent.CompletableFuture
No. of Instances - 3
No. of Commits - 3
No. of Projects - {'flink'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
Add or Remove Method invocation
executorService.submit(performUploadCallable(uploader,isFinished,false))
to
CompletableFuture.supplyAsync(performUploadSupplier(uploader,isFinished,false),executorService)
executor.submit(task)
to
CompletableFuture.runAsync(new OETLExtractorWorker(this,queue,counter),executor)
rpcManager.invokeRemotelyAsync(Collections.singletonList(address),newStatePushCommand(cache,chunk),rpcManager.getDefaultRpcOptions(true))
to
rpcManager.invokeCommand(address,newStatePushCommand(cache,chunk),SingleResponseCollector.validOnly(),rpcManager.getSyncRpcOptions()).toCompletableFuture()
CompletableFuture.completedFuture(Collections.singletonMap(address,response))
to
CompletableFuture.completedFuture(response)
syncBackupCalls
to
Objects.requireNonNull(backupCalls)
syncBackupCalls
to
Objects.requireNonNull(backupCalls)
executor.submit(partitionProducers[i])
to
CompletableFuture.supplyAsync(CheckedSupplier.unchecked(partitionProducers[i]::call),executor)
executor.submit(new TestLocalInputChannelConsumer(i,parallelism,numberOfBuffersPerChannel,networkBuffers.createBufferPool(parallelism,parallelism),partitionManager,new TaskEventDispatcher(),partitionIds))
to
CompletableFuture.supplyAsync(CheckedSupplier.unchecked(consumer::call),executor)
body
to
createSetBodyProcessor(body)
Rename Variable
tasks
to
futures
syncBackupCalls
to
backupCalls
syncBackupCalls
to
backupCalls
syncBackupCalls
to
backupCalls
syncBackupCalls
to
backupCalls
syncBackupCalls
to
backupCalls
syncBackupCalls
to
backupCalls
syncBackupCalls
to
backupCalls
combine
to
futures
combine
to
futures
Cascading Type Change (Similar)
RspList
to
RspList<Long>
Update Number Literal
10000L
to
300