Toggle navigation
Home
scala.concurrent.Future to org.apache.flink.runtime.concurrent.Future
No. of Instances - 8
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
savepointFuture.isCompleted()
to
savepointFuture.isDone()
savepointFuture.isCompleted()
to
savepointFuture.isDone()
savepointFuture.isCompleted()
to
savepointFuture.isDone()
savepointFuture.isCompleted()
to
savepointFuture.isDone()
coord.triggerSavepoint(timestampNew)
to
coord.triggerSavepoint(timestampNew,savepointDir)
savepointFuture.isCompleted()
to
savepointFuture.isDone()
savepointFuture.isCompleted()
to
savepointFuture.isDone()
coord.triggerSavepoint(i)
to
coord.triggerSavepoint(i,savepointDir)
savepointFuture.isCompleted()
to
savepointFuture.isDone()
savepointFuture2.isCompleted()
to
savepointFuture2.isDone()
savepoint0.isCompleted()
to
savepoint0.isDone()
savepointFuture1.isCompleted()
to
savepointFuture1.isDone()
savepointFuture1.isCompleted()
to
savepointFuture1.isDone()
savepointFuture1.isCompleted()
to
savepointFuture1.isDone()
savepointFuture.isCompleted()
to
savepointFuture.isDone()
savepoint1.isCompleted()
to
savepoint1.isDone()