public class OperatorSnapshotFinalizer extends Object
OperatorSnapshotFutures
. Each object is created with a OperatorSnapshotFutures
that is executed. The object can then deliver the results from the execution as OperatorSubtaskState
.Constructor and Description |
---|
OperatorSnapshotFinalizer(OperatorSnapshotFutures snapshotFutures) |
Modifier and Type | Method and Description |
---|---|
OperatorSubtaskState |
getJobManagerOwnedState() |
OperatorSubtaskState |
getTaskLocalState() |
public OperatorSnapshotFinalizer(@Nonnull OperatorSnapshotFutures snapshotFutures) throws ExecutionException, InterruptedException
public OperatorSubtaskState getTaskLocalState()
public OperatorSubtaskState getJobManagerOwnedState()
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.