public class JobManagerConnection extends Object
TaskExecutor
.Constructor and Description |
---|
JobManagerConnection(JobID jobID,
ResourceID resourceID,
JobMasterGateway jobMasterGateway,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
BlobCacheService blobService,
LibraryCacheManager libraryCacheManager,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionStateChecker) |
Modifier and Type | Method and Description |
---|---|
BlobCacheService |
getBlobService()
Gets the BLOB cache connected to the respective BLOB server instance at the job manager.
|
CheckpointResponder |
getCheckpointResponder() |
JobID |
getJobID() |
JobMasterGateway |
getJobManagerGateway() |
JobMasterId |
getJobMasterId() |
LibraryCacheManager |
getLibraryCacheManager() |
PartitionProducerStateChecker |
getPartitionStateChecker() |
ResourceID |
getResourceID() |
ResultPartitionConsumableNotifier |
getResultPartitionConsumableNotifier() |
TaskManagerActions |
getTaskManagerActions() |
public JobManagerConnection(JobID jobID, ResourceID resourceID, JobMasterGateway jobMasterGateway, TaskManagerActions taskManagerActions, CheckpointResponder checkpointResponder, BlobCacheService blobService, LibraryCacheManager libraryCacheManager, ResultPartitionConsumableNotifier resultPartitionConsumableNotifier, PartitionProducerStateChecker partitionStateChecker)
public JobID getJobID()
public ResourceID getResourceID()
public JobMasterId getJobMasterId()
public JobMasterGateway getJobManagerGateway()
public TaskManagerActions getTaskManagerActions()
public CheckpointResponder getCheckpointResponder()
public LibraryCacheManager getLibraryCacheManager()
public BlobCacheService getBlobService()
public ResultPartitionConsumableNotifier getResultPartitionConsumableNotifier()
public PartitionProducerStateChecker getPartitionStateChecker()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.