public interface PartitionProducerStateProvider
Modifier and Type | Interface and Description |
---|---|
static interface |
PartitionProducerStateProvider.ResponseHandle
Result of state query, accepts state check callbacks.
|
Modifier and Type | Method and Description |
---|---|
void |
requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId,
Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer)
Trigger the producer execution state request.
|
void requestPartitionProducerState(IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId, Consumer<? super PartitionProducerStateProvider.ResponseHandle> responseConsumer)
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.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.