Toggle navigation
Home
scala.concurrent.duration.FiniteDuration to org.apache.flink.api.common.time.Time
No. of Instances - 53
No. of Commits - 7
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update Class Instacne Creation
new AkkaRpcService(actorSystem1,new Timeout(timeout))
to
new AkkaRpcService(actorSystem1,timeout)
new AkkaRpcService(actorSystem2,new Timeout(timeout))
to
new AkkaRpcService(actorSystem2,timeout)
Add or Remove Method invocation
Await.ready(doRestart.future(),timeout)
to
doRestart.await(timeout.getSize(),timeout.getUnit())
restartDone.success(true)
to
restartDone.trigger()
blobServerAddressFuture.get(timeout.toMillis(),TimeUnit.MILLISECONDS)
to
blobServerAddressFuture.get(timeout.toMilliseconds(),TimeUnit.MILLISECONDS)
Await.result(localJobManagerAddressFuture,timeout)
to
localJobManagerAddressFuture.get(timeout.toMilliseconds(),TimeUnit.MILLISECONDS)