public class OperatorSnapshotResult extends Object
Constructor and Description |
---|
OperatorSnapshotResult() |
OperatorSnapshotResult(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture,
RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture,
RunnableFuture<OperatorStateHandle> operatorStateManagedFuture,
RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
Modifier and Type | Method and Description |
---|---|
void |
cancel() |
RunnableFuture<KeyGroupsStateHandle> |
getKeyedStateManagedFuture() |
RunnableFuture<KeyGroupsStateHandle> |
getKeyedStateRawFuture() |
RunnableFuture<OperatorStateHandle> |
getOperatorStateManagedFuture() |
RunnableFuture<OperatorStateHandle> |
getOperatorStateRawFuture() |
boolean |
hasKeyedState() |
boolean |
hasOperatorState() |
boolean |
hasState() |
void |
setKeyedStateManagedFuture(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture) |
void |
setKeyedStateRawFuture(RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture) |
void |
setOperatorStateManagedFuture(RunnableFuture<OperatorStateHandle> operatorStateManagedFuture) |
void |
setOperatorStateRawFuture(RunnableFuture<OperatorStateHandle> operatorStateRawFuture) |
public OperatorSnapshotResult()
public OperatorSnapshotResult(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture, RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture, RunnableFuture<OperatorStateHandle> operatorStateManagedFuture, RunnableFuture<OperatorStateHandle> operatorStateRawFuture)
public RunnableFuture<KeyGroupsStateHandle> getKeyedStateManagedFuture()
public void setKeyedStateManagedFuture(RunnableFuture<KeyGroupsStateHandle> keyedStateManagedFuture)
public RunnableFuture<KeyGroupsStateHandle> getKeyedStateRawFuture()
public void setKeyedStateRawFuture(RunnableFuture<KeyGroupsStateHandle> keyedStateRawFuture)
public RunnableFuture<OperatorStateHandle> getOperatorStateManagedFuture()
public void setOperatorStateManagedFuture(RunnableFuture<OperatorStateHandle> operatorStateManagedFuture)
public RunnableFuture<OperatorStateHandle> getOperatorStateRawFuture()
public void setOperatorStateRawFuture(RunnableFuture<OperatorStateHandle> operatorStateRawFuture)
public boolean hasKeyedState()
public boolean hasOperatorState()
public boolean hasState()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.