Modifier and Type | Method and Description |
---|---|
StateObjectCollection<InputChannelStateHandle> |
OperatorSubtaskState.getInputChannelState() |
StateObjectCollection<InputChannelStateHandle> |
PrioritizedOperatorSubtaskState.getPrioritizedInputChannelState() |
Modifier and Type | Method and Description |
---|---|
OperatorSubtaskState.Builder |
OperatorSubtaskState.Builder.setInputChannelState(StateObjectCollection<InputChannelStateHandle> inputChannelState) |
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–2023 The Apache Software Foundation. All rights reserved.