Package | Description |
---|---|
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.resourcemanager | |
org.apache.flink.runtime.resourcemanager.slotmanager | |
org.apache.flink.runtime.taskexecutor |
Modifier and Type | Method and Description |
---|---|
Future<Acknowledge> |
TaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
Future<Acknowledge> |
ActorTaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
Future<Acknowledge> |
TaskManagerGateway.stopTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Stop the given task.
|
Future<Acknowledge> |
ActorTaskManagerGateway.stopTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
Future<Acknowledge> |
TaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd,
Time timeout)
Submit a task to the task manager.
|
Future<Acknowledge> |
ActorTaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd,
Time timeout) |
Future<Acknowledge> |
TaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout)
Update the task where the given partitions can be found.
|
Future<Acknowledge> |
ActorTaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
Acknowledge |
JobMaster.scheduleOrUpdateConsumers(UUID leaderSessionID,
ResultPartitionID partitionID) |
Acknowledge |
JobMaster.updateTaskExecutionState(UUID leaderSessionID,
TaskExecutionState taskExecutionState)
Updates the task execution state for a given task.
|
Modifier and Type | Method and Description |
---|---|
Future<Acknowledge> |
RpcTaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
Future<Acknowledge> |
JobMasterGateway.scheduleOrUpdateConsumers(UUID leaderSessionID,
ResultPartitionID partitionID,
Time timeout)
Notifies the JobManager about available data for a produced partition.
|
Future<Acknowledge> |
RpcTaskManagerGateway.stopTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
Future<Acknowledge> |
RpcTaskManagerGateway.submitTask(TaskDeploymentDescriptor tdd,
Time timeout) |
Future<Acknowledge> |
RpcTaskManagerGateway.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos,
Time timeout) |
Future<Acknowledge> |
JobMasterGateway.updateTaskExecutionState(UUID leaderSessionID,
TaskExecutionState taskExecutionState)
Updates the task execution state for a given task.
|
Modifier and Type | Method and Description |
---|---|
static Acknowledge |
Acknowledge.get()
Gets the singleton instance.
|
Modifier and Type | Method and Description |
---|---|
Acknowledge |
ResourceManager.requestSlot(UUID jobMasterLeaderID,
UUID resourceManagerLeaderID,
SlotRequest slotRequest)
Requests a slot from the resource manager.
|
Modifier and Type | Method and Description |
---|---|
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 |
---|---|
CompletableFuture<Acknowledge> |
PendingSlotRequest.getRequestFuture() |
Modifier and Type | Method and Description |
---|---|
void |
PendingSlotRequest.setRequestFuture(CompletableFuture<Acknowledge> requestFuture) |
Modifier and Type | Method and Description |
---|---|
Acknowledge |
TaskExecutor.cancelTask(ExecutionAttemptID executionAttemptID) |
Acknowledge |
TaskExecutor.confirmCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long checkpointTimestamp) |
Acknowledge |
TaskExecutor.requestSlot(SlotID slotId,
JobID jobId,
AllocationID allocationId,
String targetAddress,
UUID rmLeaderId)
Requests a slot from the TaskManager
|
Acknowledge |
TaskExecutor.stopTask(ExecutionAttemptID executionAttemptID) |
Acknowledge |
TaskExecutor.submitTask(TaskDeploymentDescriptor tdd,
UUID jobManagerLeaderId) |
Acknowledge |
TaskExecutor.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long checkpointTimestamp,
CheckpointOptions checkpointOptions) |
Acknowledge |
TaskExecutor.updatePartitions(ExecutionAttemptID executionAttemptID,
Iterable<PartitionInfo> partitionInfos) |
Modifier and Type | Method and Description |
---|---|
Future<Acknowledge> |
TaskExecutorGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout)
Cancel the given task.
|
Future<Acknowledge> |
TaskExecutorGateway.confirmCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointId,
long checkpointTimestamp)
Confirm a checkpoint for 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.triggerCheckpoint(ExecutionAttemptID executionAttemptID,
long checkpointID,
long checkpointTimestamp,
CheckpointOptions checkpointOptions)
Trigger the checkpoint for the given task.
|
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.