Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
DispatcherGateway.cancelJob(JobID jobId,
Time timeout)
Cancel the given job.
|
CompletableFuture<Integer> |
DispatcherGateway.getBlobServerPort(Time timeout)
Returns the port of the blob server.
|
CompletableFuture<Collection<JobID>> |
DispatcherGateway.listJobs(Time timeout)
List the current set of submitted jobs.
|
CompletableFuture<Acknowledge> |
DispatcherGateway.stopJob(JobID jobId,
Time timeout)
Stop the given job.
|
CompletableFuture<Acknowledge> |
DispatcherGateway.submitJob(JobGraph jobGraph,
Time timeout)
Submit a job to the dispatcher.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
JobMasterGateway.cancel(Time timeout)
Cancels the currently executed job.
|
CompletableFuture<Collection<SlotOffer>> |
JobMasterGateway.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
Time timeout)
Offers the given slots to the job manager.
|
CompletableFuture<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
Time timeout)
Registers the task manager at the job manager.
|
CompletableFuture<AccessExecutionGraph> |
JobMasterGateway.requestArchivedExecutionGraph(Time timeout)
Request the
ArchivedExecutionGraph of the currently executed job. |
CompletableFuture<JobDetails> |
JobMasterGateway.requestJobDetails(Time timeout)
Request the details of the executed job.
|
CompletableFuture<JobStatus> |
JobMasterGateway.requestJobStatus(Time timeout)
Requests the current job status.
|
CompletableFuture<Acknowledge> |
JobMasterGateway.scheduleOrUpdateConsumers(ResultPartitionID partitionID,
Time timeout)
Notifies the JobManager about available data for a produced partition.
|
CompletableFuture<Acknowledge> |
JobMasterGateway.stop(Time timeout)
Cancel the currently executed job.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<RegistrationResponse> |
ResourceManagerGateway.registerJobManager(JobMasterId jobMasterId,
ResourceID jobMasterResourceId,
String jobMasterAddress,
JobID jobId,
Time timeout)
Register a
JobMaster at the resource manager. |
CompletableFuture<RegistrationResponse> |
ResourceManagerGateway.registerTaskExecutor(String taskExecutorAddress,
ResourceID resourceId,
SlotReport slotReport,
Time timeout)
Register a
TaskExecutor at the resource manager. |
CompletableFuture<ResourceOverview> |
ResourceManagerGateway.requestResourceOverview(Time timeout)
Requests the resource overview.
|
CompletableFuture<Acknowledge> |
ResourceManagerGateway.requestSlot(JobMasterId jobMasterId,
SlotRequest slotRequest,
Time timeout)
Requests a slot from the resource manager.
|
CompletableFuture<Collection<Tuple2<ResourceID,String>>> |
ResourceManagerGateway.requestTaskManagerMetricQueryServicePaths(Time timeout)
Requests the paths for the TaskManager's
MetricQueryService to query. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Acknowledge> |
TaskExecutorGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
CompletableFuture<Acknowledge> |
TaskExecutorGateway.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
ResourceManagerId resourceManagerId,
Time timeout)
Requests a slot from the TaskManager
|
CompletableFuture<Acknowledge> |
TaskExecutorGateway.stopTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Stop the given task.
|
CompletableFuture<Acknowledge> |
TaskExecutorGateway.submitTask(TaskDeploymentDescriptor tdd,
JobMasterId jobMasterId,
Time timeout)
Submit a
Task to the TaskExecutor . |
CompletableFuture<Acknowledge> |
TaskExecutorGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<ClusterOverview> |
RestfulGateway.requestClusterOverview(Time timeout)
Requests the cluster status overview.
|
CompletableFuture<AccessExecutionGraph> |
RestfulGateway.requestJob(JobID jobId,
Time timeout)
Requests the AccessExecutionGraph for the given jobId.
|
CompletableFuture<MultipleJobsDetails> |
RestfulGateway.requestJobDetails(boolean includeRunning,
boolean includeFinished,
Time timeout)
Requests job details currently being executed on the Flink cluster.
|
CompletableFuture<Collection<String>> |
RestfulGateway.requestMetricQueryServicePaths(Time timeout)
Requests the paths for the
MetricQueryService to query. |
CompletableFuture<String> |
RestfulGateway.requestRestAddress(Time timeout)
Requests the REST address of this
RpcEndpoint . |
CompletableFuture<Collection<Tuple2<ResourceID,String>>> |
RestfulGateway.requestTaskManagerMetricQueryServicePaths(Time timeout)
Requests the paths for the TaskManager's
MetricQueryService to query. |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.