Package | Description |
---|---|
org.apache.flink.runtime.instance | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
Future<Iterable<SlotOffer>> |
JobMasterGateway.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
UUID leaderId,
Time timeout)
Offer the given slots to the job manager.
|
Future<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId,
Time timeout)
Register the task manager at the job manager.
|
Future<Acknowledge> |
JobMasterGateway.scheduleOrUpdateConsumers(UUID leaderSessionID,
ResultPartitionID partitionID,
Time timeout)
Notifies the JobManager about available data for a produced partition.
|
Modifier and Type | Method and Description |
---|---|
Future<RegistrationResponse> |
ResourceManagerGateway.registerJobManager(UUID resourceManagerLeaderId,
UUID jobMasterLeaderId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobID,
Time timeout)
Register a
JobMaster at the resource manager. |
Future<RegistrationResponse> |
ResourceManagerGateway.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID resourceID,
SlotReport slotReport,
Time timeout)
Register a
TaskExecutor at the resource manager. |
Future<Acknowledge> |
ResourceManagerGateway.requestSlot(UUID resourceManagerLeaderID,
UUID jobMasterLeaderID,
SlotRequest slotRequest,
Time timeout)
Requests a slot from the resource manager.
|
Modifier and Type | Method and Description |
---|---|
Future<Acknowledge> |
TaskExecutorGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
Future<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID resourceManagerLeaderId,
Time timeout)
Requests a slot from the TaskManager
|
Future<Acknowledge> |
TaskExecutorGateway.stopTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Stop the given task.
|
Future<Acknowledge> |
TaskExecutorGateway.submitTask(TaskDeploymentDescriptor tdd,
UUID leaderId,
Time timeout)
Submit a
Task to the TaskExecutor . |
Future<Acknowledge> |
TaskExecutorGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.