public class JobManagerConnection extends Object
TaskExecutor
.Constructor and Description |
---|
JobManagerConnection(JobID jobID,
ResourceID resourceID,
JobMasterGateway jobMasterGateway,
UUID leaderId,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
LibraryCacheManager libraryCacheManager,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionStateChecker) |
public JobManagerConnection(JobID jobID, ResourceID resourceID, JobMasterGateway jobMasterGateway, UUID leaderId, TaskManagerActions taskManagerActions, CheckpointResponder checkpointResponder, LibraryCacheManager libraryCacheManager, ResultPartitionConsumableNotifier resultPartitionConsumableNotifier, PartitionProducerStateChecker partitionStateChecker)
public JobID getJobID()
public ResourceID getResourceID()
public UUID getLeaderId()
public JobMasterGateway getJobManagerGateway()
public TaskManagerActions getTaskManagerActions()
public CheckpointResponder getCheckpointResponder()
public LibraryCacheManager getLibraryCacheManager()
public ResultPartitionConsumableNotifier getResultPartitionConsumableNotifier()
public PartitionProducerStateChecker getPartitionStateChecker()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.