Package | Description |
---|---|
org.apache.flink.runtime.resourcemanager.registration | |
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.runtime.taskexecutor.rpc |
Modifier and Type | Method and Description |
---|---|
JobMasterGateway |
JobManagerRegistration.getJobManagerGateway() |
Constructor and Description |
---|
JobManagerRegistration(JobID jobID,
ResourceID jobManagerResourceID,
UUID leaderID,
JobMasterGateway jobManagerGateway) |
Modifier and Type | Method and Description |
---|---|
JobMasterGateway |
JobManagerConnection.getJobManagerGateway() |
Modifier and Type | Method and Description |
---|---|
void |
JobLeaderListener.jobManagerGainedLeadership(JobID jobId,
JobMasterGateway jobManagerGateway,
UUID jobLeaderId,
JMTMRegistrationSuccess registrationMessage)
Callback if a job manager has gained leadership for the job identified by the job id and a
connection could be established to this job manager.
|
Constructor and Description |
---|
JobManagerConnection(JobID jobID,
ResourceID resourceID,
JobMasterGateway jobMasterGateway,
UUID leaderId,
TaskManagerActions taskManagerActions,
CheckpointResponder checkpointResponder,
LibraryCacheManager libraryCacheManager,
ResultPartitionConsumableNotifier resultPartitionConsumableNotifier,
PartitionProducerStateChecker partitionStateChecker) |
Constructor and Description |
---|
RpcInputSplitProvider(UUID jobMasterLeaderId,
JobMasterGateway jobMasterGateway,
JobID jobID,
JobVertexID jobVertexID,
ExecutionAttemptID executionAttemptID,
Time timeout) |
RpcPartitionStateChecker(UUID jobMasterLeaderId,
JobMasterGateway jobMasterGateway) |
RpcResultPartitionConsumableNotifier(UUID jobMasterLeaderId,
JobMasterGateway jobMasterGateway,
Executor executor,
Time timeout) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.