public static interface JobTable.Connection
A connection can be disconnected by calling disconnect(). Disconnecting a
connection will close all services bound to the connection and return the remaining job
instance.
Accessing any methods after a connection has been disconnected will throw an IllegalStateException.
| Modifier and Type | Method and Description |
|---|---|
JobTable.Job |
disconnect()
Disconnects the connection, closing all associated services thereby and returning the
remaining job.
|
CheckpointResponder |
getCheckpointResponder() |
LibraryCacheManager.ClassLoaderHandle |
getClassLoaderHandle() |
GlobalAggregateManager |
getGlobalAggregateManager() |
JobID |
getJobId() |
JobMasterGateway |
getJobManagerGateway() |
JobMasterId |
getJobMasterId() |
PartitionProducerStateChecker |
getPartitionStateChecker() |
ResourceID |
getResourceId() |
ResultPartitionConsumableNotifier |
getResultPartitionConsumableNotifier() |
TaskManagerActions |
getTaskManagerActions() |
JobTable.Job disconnect()
JobMasterId getJobMasterId()
JobMasterGateway getJobManagerGateway()
TaskManagerActions getTaskManagerActions()
CheckpointResponder getCheckpointResponder()
GlobalAggregateManager getGlobalAggregateManager()
LibraryCacheManager.ClassLoaderHandle getClassLoaderHandle()
ResultPartitionConsumableNotifier getResultPartitionConsumableNotifier()
PartitionProducerStateChecker getPartitionStateChecker()
JobID getJobId()
ResourceID getResourceId()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.