public class OperatorSnapshotFutures extends Object
Constructor and Description |
---|
OperatorSnapshotFutures() |
OperatorSnapshotFutures(RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture,
RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture,
RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture,
RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture,
Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture,
Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture) |
public OperatorSnapshotFutures()
public OperatorSnapshotFutures(@Nonnull RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture, @Nonnull RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture, @Nonnull RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture, @Nonnull RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture, @Nonnull Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture, @Nonnull Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture)
@Nonnull public RunnableFuture<SnapshotResult<KeyedStateHandle>> getKeyedStateManagedFuture()
public void setKeyedStateManagedFuture(@Nonnull RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateManagedFuture)
@Nonnull public RunnableFuture<SnapshotResult<KeyedStateHandle>> getKeyedStateRawFuture()
public void setKeyedStateRawFuture(@Nonnull RunnableFuture<SnapshotResult<KeyedStateHandle>> keyedStateRawFuture)
@Nonnull public RunnableFuture<SnapshotResult<OperatorStateHandle>> getOperatorStateManagedFuture()
public void setOperatorStateManagedFuture(@Nonnull RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateManagedFuture)
@Nonnull public RunnableFuture<SnapshotResult<OperatorStateHandle>> getOperatorStateRawFuture()
public void setOperatorStateRawFuture(@Nonnull RunnableFuture<SnapshotResult<OperatorStateHandle>> operatorStateRawFuture)
@Nonnull public Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> getInputChannelStateFuture()
public void setInputChannelStateFuture(@Nonnull Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture)
@Nonnull public Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> getResultSubpartitionStateFuture()
public void setResultSubpartitionStateFuture(@Nonnull Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture)
public Future<?>[] getAllFutures()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.