Package org.apache.flink.streaming.api.operators

Class OperatorSnapshotFinalizer

java.lang.Object

org.apache.flink.streaming.api.operators.OperatorSnapshotFinalizer

public class OperatorSnapshotFinalizer
extends Object

This class finalizes OperatorSnapshotFutures. Each object is created with a OperatorSnapshotFutures that is executed. The object can then deliver the results from the execution as OperatorSubtaskState.

Constructor Summary

Constructors

Constructor	Description
OperatorSnapshotFinalizer(OperatorSubtaskState jobManagerOwnedState, OperatorSubtaskState taskLocalState)

Method Summary

Modifier and Type	Method	Description
static OperatorSnapshotFinalizer	create(OperatorSnapshotFutures snapshotFutures)
OperatorSubtaskState	getJobManagerOwnedState()
OperatorSubtaskState	getTaskLocalState()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperatorSnapshotFinalizer

public OperatorSnapshotFinalizer(OperatorSubtaskState jobManagerOwnedState,
                                 OperatorSubtaskState taskLocalState)

Method Detail

create

public static OperatorSnapshotFinalizer create(OperatorSnapshotFutures snapshotFutures)
                                        throws ExecutionException,
                                               InterruptedException

Throws:

ExecutionException

InterruptedException

getTaskLocalState

public OperatorSubtaskState getTaskLocalState()

getJobManagerOwnedState

public OperatorSubtaskState getJobManagerOwnedState()