public class ActorGatewayPartitionProducerStateChecker extends Object implements PartitionProducerStateChecker
ActorGateway
to trigger the partition state check at the job
manager.Constructor and Description |
---|
ActorGatewayPartitionProducerStateChecker(ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration timeout) |
Modifier and Type | Method and Description |
---|---|
Future<ExecutionState> |
requestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId)
Requests the execution state of the execution producing a result partition.
|
public ActorGatewayPartitionProducerStateChecker(ActorGateway jobManager, scala.concurrent.duration.FiniteDuration timeout)
public Future<ExecutionState> requestPartitionProducerState(JobID jobId, IntermediateDataSetID intermediateDataSetId, ResultPartitionID resultPartitionId)
PartitionProducerStateChecker
requestPartitionProducerState
in interface PartitionProducerStateChecker
jobId
- ID of the job the partition belongs to.intermediateDataSetId
- ID of the parent intermediate data set.resultPartitionId
- ID of the result partition to check. This
identifies the producing execution and partition.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.