Uses of Interface
org.apache.flink.runtime.io.network.partition.PartitionProducerStateProvider.ResponseHandle

Packages that use PartitionProducerStateProvider.ResponseHandle

Package	Description
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.taskmanager

Uses of PartitionProducerStateProvider.ResponseHandle in org.apache.flink.runtime.io.network.partition

Method parameters in org.apache.flink.runtime.io.network.partition with type arguments of type PartitionProducerStateProvider.ResponseHandle

Modifier and Type	Method and Description
void	PartitionProducerStateProvider.requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId, java.util.function.Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer) Trigger the producer execution state request.

Uses of PartitionProducerStateProvider.ResponseHandle in org.apache.flink.runtime.io.network.partition.consumer

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type PartitionProducerStateProvider.ResponseHandle

Modifier and Type	Method and Description
boolean	RemoteChannelStateChecker.isProducerReadyOrAbortConsumption(PartitionProducerStateProvider.ResponseHandle responseHandle)

Uses of PartitionProducerStateProvider.ResponseHandle in org.apache.flink.runtime.taskmanager

Method parameters in org.apache.flink.runtime.taskmanager with type arguments of type PartitionProducerStateProvider.ResponseHandle

Modifier and Type	Method and Description
void	Task.requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId, java.util.function.Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer)