org.apache.flink.runtime.io.network.partition

Interface PartitionProducerStateProvider

All Known Implementing Classes:

Task

public interface PartitionProducerStateProvider

Request execution state of partition producer, the response accepts state check callbacks.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	PartitionProducerStateProvider.ResponseHandle Result of state query, accepts state check callbacks.

Method Summary

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

Method Detail

requestPartitionProducerState

void requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId,
                                   ResultPartitionID resultPartitionId,
                                   java.util.function.Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer)

Trigger the producer execution state request.

Parameters:

intermediateDataSetId - ID of the parent intermediate data set.

resultPartitionId - ID of the result partition to check. This identifies the producing execution and partition.

responseConsumer - consumer for the response handle.