org.apache.flink.streaming.api.operators

Class OperatorSnapshotResult

java.lang.Object

org.apache.flink.streaming.api.operators.OperatorSnapshotResult

public class OperatorSnapshotResult
extends Object

Result of StreamOperator.snapshotState(long, long, org.apache.flink.runtime.checkpoint.CheckpointOptions).

Constructor Summary

Constructors

Constructor and Description
OperatorSnapshotResult()
OperatorSnapshotResult(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture, RunnableFuture<KeyedStateHandle> keyedStateRawFuture, RunnableFuture<OperatorStateHandle> operatorStateManagedFuture, RunnableFuture<OperatorStateHandle> operatorStateRawFuture)

Method Summary

Modifier and Type	Method and Description
void	cancel()
RunnableFuture<KeyedStateHandle>	getKeyedStateManagedFuture()
RunnableFuture<KeyedStateHandle>	getKeyedStateRawFuture()
RunnableFuture<OperatorStateHandle>	getOperatorStateManagedFuture()
RunnableFuture<OperatorStateHandle>	getOperatorStateRawFuture()
boolean	hasKeyedState()
boolean	hasOperatorState()
boolean	hasState()
void	setKeyedStateManagedFuture(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture)
void	setKeyedStateRawFuture(RunnableFuture<KeyedStateHandle> keyedStateRawFuture)
void	setOperatorStateManagedFuture(RunnableFuture<OperatorStateHandle> operatorStateManagedFuture)
void	setOperatorStateRawFuture(RunnableFuture<OperatorStateHandle> operatorStateRawFuture)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorSnapshotResult

public OperatorSnapshotResult()

OperatorSnapshotResult

public OperatorSnapshotResult(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture,
                              RunnableFuture<KeyedStateHandle> keyedStateRawFuture,
                              RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
                              RunnableFuture<OperatorStateHandle> operatorStateRawFuture)

Method Detail

getKeyedStateManagedFuture

public RunnableFuture<KeyedStateHandle> getKeyedStateManagedFuture()

setKeyedStateManagedFuture

public void setKeyedStateManagedFuture(RunnableFuture<KeyedStateHandle> keyedStateManagedFuture)

getKeyedStateRawFuture

public RunnableFuture<KeyedStateHandle> getKeyedStateRawFuture()

setKeyedStateRawFuture

public void setKeyedStateRawFuture(RunnableFuture<KeyedStateHandle> keyedStateRawFuture)

getOperatorStateManagedFuture

public RunnableFuture<OperatorStateHandle> getOperatorStateManagedFuture()

setOperatorStateManagedFuture

public void setOperatorStateManagedFuture(RunnableFuture<OperatorStateHandle> operatorStateManagedFuture)

getOperatorStateRawFuture

public RunnableFuture<OperatorStateHandle> getOperatorStateRawFuture()

setOperatorStateRawFuture

public void setOperatorStateRawFuture(RunnableFuture<OperatorStateHandle> operatorStateRawFuture)

cancel

public void cancel()
            throws Exception

Throws:

Exception

hasKeyedState

public boolean hasKeyedState()

hasOperatorState

public boolean hasOperatorState()

hasState

public boolean hasState()