Modifier and Type | Method and Description |
---|---|
StateObjectCollection<ResultSubpartitionStateHandle> |
PrioritizedOperatorSubtaskState.getPrioritizedResultSubpartitionState() |
StateObjectCollection<ResultSubpartitionStateHandle> |
OperatorSubtaskState.getResultSubpartitionState() |
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<ResultSubpartitionStateHandle>> |
ChannelStateWriter.ChannelStateWriteResult.getResultSubpartitionStateHandles() |
Modifier and Type | Method and Description |
---|---|
StateObjectCollection<ResultSubpartitionStateHandle> |
MetadataV3Serializer.deserializeResultSubpartitionStateHandle(DataInputStream dis) |
StateObjectCollection<ResultSubpartitionStateHandle> |
MetadataV3Serializer.deserializeResultSubpartitionStateHandle(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
protected StateObjectCollection<ResultSubpartitionStateHandle> |
MetadataV2V3SerializerBase.deserializeResultSubpartitionStateHandle(DataInputStream dis,
MetadataV2V3SerializerBase.DeserializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MetadataV3Serializer.serializeResultSubpartitionStateHandle(ResultSubpartitionStateHandle handle,
DataOutputStream dos) |
protected void |
MetadataV2V3SerializerBase.serializeResultSubpartitionStateHandle(ResultSubpartitionStateHandle resultSubpartitionStateHandle,
DataOutputStream dos) |
Modifier and Type | Method and Description |
---|---|
Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> |
OperatorSnapshotFutures.getResultSubpartitionStateFuture() |
Modifier and Type | Method and Description |
---|---|
void |
OperatorSnapshotFutures.setResultSubpartitionStateFuture(Future<SnapshotResult<StateObjectCollection<ResultSubpartitionStateHandle>>> resultSubpartitionStateFuture) |
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.