Modifier and Type | Method and Description |
---|---|
StateObjectCollection<InputChannelStateHandle> |
OperatorSubtaskState.getInputChannelState() |
StateObjectCollection<InputChannelStateHandle> |
PrioritizedOperatorSubtaskState.getPrioritizedInputChannelState() |
Modifier and Type | Method and Description |
---|---|
static OperatorSubtaskState |
StateAssignmentOperation.operatorSubtaskStateFrom(OperatorInstanceID instanceID,
Map<OperatorInstanceID,List<OperatorStateHandle>> subManagedOperatorState,
Map<OperatorInstanceID,List<OperatorStateHandle>> subRawOperatorState,
Map<OperatorInstanceID,List<InputChannelStateHandle>> inputChannelStates,
Map<OperatorInstanceID,List<ResultSubpartitionStateHandle>> resultSubpartitionStates,
Map<OperatorInstanceID,List<KeyedStateHandle>> subManagedKeyedState,
Map<OperatorInstanceID,List<KeyedStateHandle>> subRawKeyedState) |
Constructor and Description |
---|
OperatorSubtaskState(OperatorStateHandle managedOperatorState,
OperatorStateHandle rawOperatorState,
KeyedStateHandle managedKeyedState,
KeyedStateHandle rawKeyedState,
StateObjectCollection<InputChannelStateHandle> inputChannelState,
StateObjectCollection<ResultSubpartitionStateHandle> resultSubpartitionState)
For convenience because the size of the collections is typically 0 or 1.
|
OperatorSubtaskState(StateObjectCollection<OperatorStateHandle> managedOperatorState,
StateObjectCollection<OperatorStateHandle> rawOperatorState,
StateObjectCollection<KeyedStateHandle> managedKeyedState,
StateObjectCollection<KeyedStateHandle> rawKeyedState,
StateObjectCollection<InputChannelStateHandle> inputChannelState,
StateObjectCollection<ResultSubpartitionStateHandle> resultSubpartitionState) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Collection<InputChannelStateHandle>> |
ChannelStateWriter.ChannelStateWriteResult.getInputChannelStateHandles() |
Modifier and Type | Method and Description |
---|---|
static StateObjectCollection<InputChannelStateHandle> |
MetadataV3Serializer.deserializeInputChannelStateHandle(DataInputStream dis) |
StateObjectCollection<InputChannelStateHandle> |
MetadataV3Serializer.deserializeInputChannelStateHandle(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
protected StateObjectCollection<InputChannelStateHandle> |
MetadataV2V3SerializerBase.deserializeInputChannelStateHandle(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataV3Serializer.serializeInputChannelStateHandle(InputChannelStateHandle handle,
DataOutputStream dos) |
protected void |
MetadataV2V3SerializerBase.serializeInputChannelStateHandle(InputChannelStateHandle inputChannelStateHandle,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> |
OperatorSnapshotFutures.getInputChannelStateFuture() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSnapshotFutures.setInputChannelStateFuture(Future<SnapshotResult<StateObjectCollection<InputChannelStateHandle>>> inputChannelStateFuture) |
Constructor and Description |
---|
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) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.