public static class JobManagerMessages.ScheduleOrUpdateConsumers extends Object implements RequiresLeaderSessionID, scala.Product, scala.Serializable
JobManager
about available data for a
produced partition.
There is a call to this method for each
ExecutionVertex
instance once per produced
ResultPartition
instance,
either when first producing data (for pipelined executions) or when all data has been produced
(for staged executions).
The JobManager
then can decide when to schedule the
partition consumers of the given session.
ResultPartition
,
Serialized FormConstructor and Description |
---|
ScheduleOrUpdateConsumers(JobID jobId,
ResultPartitionID partitionId) |
Modifier and Type | Method and Description |
---|---|
JobID |
jobId() |
ResultPartitionID |
partitionId() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ScheduleOrUpdateConsumers(JobID jobId, ResultPartitionID partitionId)
public JobID jobId()
public ResultPartitionID partitionId()
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.