Toggle navigation
Home
scala.concurrent.Future to java.util.concurrent.CompletableFuture
No. of Instances - 29
No. of Commits - 2
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
Await.result(localJobManagerAddressFuture,timeout)
to
localJobManagerAddressFuture.get(timeout.toMilliseconds(),TimeUnit.MILLISECONDS)
localJobManagerAddressFuture.isCompleted()
to
localJobManagerAddressFuture.isDone()
Await.result(localJobManagerAddressFuture,timeout)
to
localJobManagerAddressFuture.get()
localJobManagerAddressFuture.isCompleted()
to
localJobManagerAddressFuture.isDone()
testActorSystem.dispatcher()
to
NO_OF_RETRIES
testActorSystem.dispatcher()
to
failForUnknownKeyOrNamespace
recoverWith
to
retryWithDelay
client.getKvState(serverAddress,request,new byte[0])
to
client.sendRequest(serverAddress,request)
flatMap
to
thenApply
Rename Variable
future
to
unsuccessfulCancelWithSavepoint
Other
new KvStateID()
to
request
Cascading Type Change (Different)
Mapper<byte[],Future<V>>
to
FlinkRuntimeException