public static interface JobTable.Job
Accessing any methods after a job has been closed will throw an
|Modifier and Type||Method and Description|
Returns the associated
Closes this job and removes it from the owning
Connects the job to a JobManager and associates the provided services with this connection.
trueif the job is connected to a JobManager.
trueif the job is connected to a JobManager, otherwise
JobIDwhich is associated with this job.
JobTable.Connectionif the job is connected to a JobManager.
Optionalcontaining the associated
JobTable.Connectioninstance if the job is connected to a leading JobManager, or an empty
Optionalif the job is not connected
JobTable.Connection connect(ResourceID resourceId, JobMasterGateway jobMasterGateway, TaskManagerActions taskManagerActions, CheckpointResponder checkpointResponder, GlobalAggregateManager aggregateManager, ResultPartitionConsumableNotifier resultPartitionConsumableNotifier, PartitionProducerStateChecker partitionStateChecker)
A job can only be connected iff
Job#isConnected() == false.
resourceId- resourceId of the JobManager to connect to
jobMasterGateway- jobMasterGateway of the JobManager to connect to
taskManagerActions- taskManagerActions associated with this connection
checkpointResponder- checkpointResponder associated with this connection
aggregateManager- aggregateManager associated with this connection
resultPartitionConsumableNotifier- resultPartitionConsumableNotifier associated with this connection
partitionStateChecker- partitionStateChecker associated with this connection
IllegalStateException- if the job is already connected
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.