Modifier and Type | Method and Description |
---|---|
StateObjectCollection<ResultSubpartitionStateHandle> |
PrioritizedOperatorSubtaskState.getPrioritizedResultSubpartitionState() |
StateObjectCollection<ResultSubpartitionStateHandle> |
OperatorSubtaskState.getResultSubpartitionState() |
Modifier and Type | Method and Description |
---|---|
OperatorSubtaskState.Builder |
OperatorSubtaskState.Builder.setResultSubpartitionState(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–2023 The Apache Software Foundation. All rights reserved.