public class ChannelStatePendingResult extends Object
Constructor and Description |
---|
ChannelStatePendingResult(int subtaskIndex,
long checkpointId,
ChannelStateWriter.ChannelStateWriteResult result,
org.apache.flink.runtime.checkpoint.channel.ChannelStateSerializer serializer) |
Modifier and Type | Method and Description |
---|---|
void |
fail(Throwable e) |
void |
finishResult(StreamStateHandle stateHandle) |
Map<InputChannelInfo,AbstractChannelStateHandle.StateContentMetaInfo> |
getInputChannelOffsets() |
Map<ResultSubpartitionInfo,AbstractChannelStateHandle.StateContentMetaInfo> |
getResultSubpartitionOffsets() |
boolean |
isAllInputsReceived() |
boolean |
isAllOutputsReceived() |
boolean |
isDone() |
public ChannelStatePendingResult(int subtaskIndex, long checkpointId, ChannelStateWriter.ChannelStateWriteResult result, org.apache.flink.runtime.checkpoint.channel.ChannelStateSerializer serializer)
public boolean isAllInputsReceived()
public boolean isAllOutputsReceived()
public Map<InputChannelInfo,AbstractChannelStateHandle.StateContentMetaInfo> getInputChannelOffsets()
public Map<ResultSubpartitionInfo,AbstractChannelStateHandle.StateContentMetaInfo> getResultSubpartitionOffsets()
public void finishResult(@Nullable StreamStateHandle stateHandle) throws IOException
IOException
public void fail(Throwable e)
public boolean isDone()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.