org.apache.flink.runtime.taskexecutor

Class JobManagerConnection

java.lang.Object

org.apache.flink.runtime.taskexecutor.JobManagerConnection

public class JobManagerConnection
extends Object

Container class for JobManager specific communication utils used by the TaskExecutor.

Constructor Summary

Constructors

Constructor and Description
JobManagerConnection(JobID jobID, ResourceID resourceID, JobMasterGateway jobMasterGateway, TaskManagerActions taskManagerActions, CheckpointResponder checkpointResponder, LibraryCacheManager libraryCacheManager, ResultPartitionConsumableNotifier resultPartitionConsumableNotifier, PartitionProducerStateChecker partitionStateChecker)

Method Summary

Modifier and Type	Method and Description
CheckpointResponder	getCheckpointResponder()
JobID	getJobID()
JobMasterGateway	getJobManagerGateway()
JobMasterId	getJobMasterId()
LibraryCacheManager	getLibraryCacheManager()
PartitionProducerStateChecker	getPartitionStateChecker()
ResourceID	getResourceID()
ResultPartitionConsumableNotifier	getResultPartitionConsumableNotifier()
TaskManagerActions	getTaskManagerActions()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobManagerConnection

public JobManagerConnection(JobID jobID,
                            ResourceID resourceID,
                            JobMasterGateway jobMasterGateway,
                            TaskManagerActions taskManagerActions,
                            CheckpointResponder checkpointResponder,
                            LibraryCacheManager libraryCacheManager,
                            ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
                            PartitionProducerStateChecker partitionStateChecker)

Method Detail

getJobID

public JobID getJobID()

getResourceID

public ResourceID getResourceID()

getJobMasterId

public JobMasterId getJobMasterId()

getJobManagerGateway

public JobMasterGateway getJobManagerGateway()

getTaskManagerActions

public TaskManagerActions getTaskManagerActions()

getCheckpointResponder

public CheckpointResponder getCheckpointResponder()

getLibraryCacheManager

public LibraryCacheManager getLibraryCacheManager()

getResultPartitionConsumableNotifier

public ResultPartitionConsumableNotifier getResultPartitionConsumableNotifier()

getPartitionStateChecker

public PartitionProducerStateChecker getPartitionStateChecker()