Modifier and Type | Method and Description |
---|---|
Future<CompletedCheckpoint> |
PendingCheckpoint.getCompletionFuture()
Returns the completion future.
|
Future<CompletedCheckpoint> |
CheckpointCoordinator.triggerCheckpoint(long timestamp,
CheckpointOptions options)
Test method to trigger a checkpoint/savepoint.
|
Future<T> |
MasterTriggerRestoreHook.triggerCheckpoint(long checkpointId,
long timestamp,
Executor executor)
This method is called by the checkpoint coordinator prior when triggering a checkpoint, prior
to sending the "trigger checkpoint" messages to the source tasks.
|
Future<CompletedCheckpoint> |
CheckpointCoordinator.triggerSavepoint(long timestamp,
String targetDirectory)
Triggers a savepoint with the given savepoint directory as a target.
|
Modifier and Type | Interface and Description |
---|---|
interface |
CompletableFuture<T>
Flink's completable future abstraction.
|
static interface |
FutureUtils.ConjunctFuture<T>
A future that is complete once multiple other futures completed.
|
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
Future.exceptionally(ApplyFunction<Throwable,? extends R> exceptionallyFunction)
Applies the given function to the value of the future if the future has been completed
exceptionally.
|
<R> Future<R> |
Future.exceptionallyAsync(ApplyFunction<Throwable,? extends R> exceptionallyFunction,
Executor executor)
Applies the given function to the value of the future if the future has been completed
exceptionally.
|
<R> Future<R> |
Future.handle(BiFunction<? super T,Throwable,? extends R> biFunction)
Applies the given handle function to the result of the future.
|
<R> Future<R> |
Future.handleAsync(BiFunction<? super T,Throwable,? extends R> biFunction,
Executor executor)
Applies the given handle function to the result of the future.
|
static <T> Future<T> |
FutureUtils.retry(Callable<Future<T>> operation,
int retries,
Executor executor)
Retry the given operation the given number of times in case of a failure.
|
static <T> Future<T> |
FutureUtils.retrySuccessful(Callable<Future<T>> operation,
FilterFunction<T> successPredicate,
scala.concurrent.duration.Deadline deadline,
Executor executor)
Retry the given operation the given number of times in case of a failure.
|
Future<Void> |
Future.thenAccept(AcceptFunction<? super T> acceptFunction)
Applies the accept function to the value of the future.
|
Future<Void> |
Future.thenAcceptAsync(AcceptFunction<? super T> acceptFunction,
Executor executor)
Applies the accept function to the value of the future.
|
<R> Future<R> |
Future.thenApply(ApplyFunction<? super T,? extends R> applyFunction)
Applies the given function to the value of the future.
|
<R> Future<R> |
Future.thenApplyAsync(ApplyFunction<? super T,? extends R> applyFunction,
Executor executor)
Applies the given function to the value of the future.
|
<U,R> Future<R> |
Future.thenCombine(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction)
Applies the given function to the result of this and the other future after both futures
have completed.
|
<U,R> Future<R> |
Future.thenCombineAsync(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction,
Executor executor)
Applies the given function to the result of this and the other future after both futures
have completed.
|
<R> Future<R> |
Future.thenCompose(ApplyFunction<? super T,? extends Future<R>> composeFunction)
Applies the given function to the value of the future.
|
<R> Future<R> |
Future.thenComposeAsync(ApplyFunction<? super T,? extends Future<R>> composeFunction,
Executor executor)
Applies the given function to the value of the future.
|
Modifier and Type | Method and Description |
---|---|
<U,R> Future<R> |
Future.thenCombine(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction)
Applies the given function to the result of this and the other future after both futures
have completed.
|
<U,R> Future<R> |
Future.thenCombineAsync(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction,
Executor executor)
Applies the given function to the result of this and the other future after both futures
have completed.
|
Modifier and Type | Method and Description |
---|---|
static <T> FutureUtils.ConjunctFuture<Collection<T>> |
FutureUtils.combineAll(Collection<? extends Future<? extends T>> futures)
Creates a future that is complete once multiple other futures completed.
|
static <T> Future<T> |
FutureUtils.retry(Callable<Future<T>> operation,
int retries,
Executor executor)
Retry the given operation the given number of times in case of a failure.
|
static <T> Future<T> |
FutureUtils.retrySuccessful(Callable<Future<T>> operation,
FilterFunction<T> successPredicate,
scala.concurrent.duration.Deadline deadline,
Executor executor)
Retry the given operation the given number of times in case of a failure.
|
<R> Future<R> |
Future.thenCompose(ApplyFunction<? super T,? extends Future<R>> composeFunction)
Applies the given function to the value of the future.
|
<R> Future<R> |
Future.thenComposeAsync(ApplyFunction<? super T,? extends Future<R>> composeFunction,
Executor executor)
Applies the given function to the value of the future.
|
static FutureUtils.ConjunctFuture<Void> |
FutureUtils.waitForAll(Collection<? extends Future<?>> futures)
Creates a future that is complete once all of the given futures have completed.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkCompletableFuture<T>
Implementation of
CompletableFuture which is backed by Promise . |
class |
FlinkFuture<T>
Implementation of
Future which is backed by Future . |
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
FlinkFuture.exceptionally(ApplyFunction<Throwable,? extends R> exceptionallyFunction) |
<R> Future<R> |
FlinkFuture.exceptionallyAsync(ApplyFunction<Throwable,? extends R> exceptionallyFunction,
Executor executor) |
<R> Future<R> |
FlinkFuture.handle(BiFunction<? super T,Throwable,? extends R> biFunction) |
<R> Future<R> |
FlinkFuture.handleAsync(BiFunction<? super T,Throwable,? extends R> biFunction,
Executor executor) |
static <T> Future<T> |
FlinkFuture.supplyAsync(Callable<T> callable,
Executor executor)
Creates a future whose value is determined by the asynchronously executed callable.
|
Future<Void> |
FlinkFuture.thenAccept(AcceptFunction<? super T> acceptFunction) |
Future<Void> |
FlinkFuture.thenAcceptAsync(AcceptFunction<? super T> acceptFunction,
Executor executor) |
<R> Future<R> |
FlinkFuture.thenApply(ApplyFunction<? super T,? extends R> applyFunction) |
<R> Future<R> |
FlinkFuture.thenApplyAsync(ApplyFunction<? super T,? extends R> applyFunction,
Executor executor) |
<U,R> Future<R> |
FlinkFuture.thenCombine(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction) |
<U,R> Future<R> |
FlinkFuture.thenCombineAsync(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction,
Executor executor) |
<R> Future<R> |
FlinkFuture.thenCompose(ApplyFunction<? super T,? extends Future<R>> composeFunction) |
<R> Future<R> |
FlinkFuture.thenComposeAsync(ApplyFunction<? super T,? extends Future<R>> applyFunction,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
<U,R> Future<R> |
FlinkFuture.thenCombine(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction) |
<U,R> Future<R> |
FlinkFuture.thenCombineAsync(Future<U> other,
BiFunction<? super T,? super U,? extends R> biFunction,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
<R> Future<R> |
FlinkFuture.thenCompose(ApplyFunction<? super T,? extends Future<R>> composeFunction) |
<R> Future<R> |
FlinkFuture.thenComposeAsync(ApplyFunction<? super T,? extends Future<R>> applyFunction,
Executor executor) |
Modifier and Type | Field and Description |
---|---|
Future<SimpleSlot> |
ExecutionAndSlot.slotFuture |
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
Execution.allocateSlotForExecution(SlotProvider slotProvider,
boolean queued) |
Future<ExecutionState> |
ExecutionVertex.cancel() |
Future<Void> |
ExecutionJobVertex.cancelWithFuture()
Cancels all currently running vertex executions.
|
Future<JobStatus> |
ExecutionGraph.getTerminationFuture() |
Future<ExecutionState> |
Execution.getTerminationFuture()
Gets a future that completes once the task execution reaches a terminal state.
|
Future<StackTraceSampleResponse> |
Execution.requestStackTraceSample(int sampleId,
int numSamples,
Time delayBetweenSamples,
int maxStrackTraceDepth,
Time timeout)
Request a stack trace sample from the task of this execution.
|
Modifier and Type | Method and Description |
---|---|
static void |
ExecutionGraphUtils.releaseSlotFuture(Future<SimpleSlot> slotFuture)
Releases the slot represented by the given future.
|
Constructor and Description |
---|
ExecutionAndSlot(Execution executionAttempt,
Future<SimpleSlot> slotFuture) |
Modifier and Type | Method and Description |
---|---|
Future<O> |
HeartbeatListener.retrievePayload()
Retrieves the payload value for the next heartbeat message.
|
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
SlotProvider.allocateSlot(ScheduledUnit task,
boolean allowQueued)
Allocating slot with specific requirement.
|
Future<SimpleSlot> |
SlotPool.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences) |
Future<SimpleSlot> |
SlotPoolGateway.allocateSlot(ScheduledUnit task,
ResourceProfile resources,
Iterable<TaskManagerLocation> locationPreferences,
Time timeout) |
Future<Boolean> |
SlotPoolGateway.offerSlot(AllocatedSlot slot) |
Future<Iterable<SlotOffer>> |
SlotPoolGateway.offerSlots(Iterable<Tuple2<AllocatedSlot,SlotOffer>> offers) |
Modifier and Type | Method and Description |
---|---|
Future<ExecutionState> |
PartitionProducerStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId)
Requests the execution state of the execution producing a result partition.
|
Modifier and Type | Method and Description |
---|---|
Future<SimpleSlot> |
Scheduler.allocateSlot(ScheduledUnit task,
boolean allowQueued) |
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<StackTrace> |
TaskManagerGateway.requestStackTrace(Time timeout)
Request the stack trace from the task manager.
|
Future<StackTrace> |
ActorTaskManagerGateway.requestStackTrace(Time timeout) |
Future<StackTraceSampleResponse> |
TaskManagerGateway.requestStackTraceSample(ExecutionAttemptID executionAttemptID,
int sampleId,
int numSamples,
Time delayBetweenSamples,
int maxStackTraceDepth,
Time timeout)
Request a stack trace sample from the given task.
|
Future<StackTraceSampleResponse> |
ActorTaskManagerGateway.requestStackTraceSample(ExecutionAttemptID executionAttemptID,
int sampleId,
int numSamples,
Time delayBetweenSamples,
int maxStackTraceDepth,
Time timeout) |
Future<BlobKey> |
TaskManagerGateway.requestTaskManagerLog(Time timeout)
Request the task manager log from the task manager.
|
Future<BlobKey> |
ActorTaskManagerGateway.requestTaskManagerLog(Time timeout) |
Future<BlobKey> |
TaskManagerGateway.requestTaskManagerStdout(Time timeout)
Request the task manager stdout from the task manager.
|
Future<BlobKey> |
ActorTaskManagerGateway.requestTaskManagerStdout(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 |
---|---|
Future<Acknowledge> |
RpcTaskManagerGateway.cancelTask(ExecutionAttemptID executionAttemptID,
Time timeout) |
Future<KvStateLocation> |
JobMasterGateway.lookupKvStateLocation(String registrationName)
Requests a
KvStateLocation for the specified InternalKvState registration name. |
Future<Iterable<SlotOffer>> |
JobMaster.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
UUID leaderId) |
Future<Iterable<SlotOffer>> |
JobMasterGateway.offerSlots(ResourceID taskManagerId,
Iterable<SlotOffer> slots,
UUID leaderId,
Time timeout)
Offer the given slots to the job manager.
|
Future<RegistrationResponse> |
JobMaster.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId) |
Future<RegistrationResponse> |
JobMasterGateway.registerTaskManager(String taskManagerRpcAddress,
TaskManagerLocation taskManagerLocation,
UUID leaderId,
Time timeout)
Register the task manager at the job manager.
|
Future<ClassloadingProps> |
JobMasterGateway.requestClassloadingProps()
Request the classloading props of this job.
|
Future<SerializedInputSplit> |
JobMasterGateway.requestNextInputSplit(UUID leaderSessionID,
JobVertexID vertexID,
ExecutionAttemptID executionAttempt)
Requesting next input split for the
ExecutionJobVertex . |
Future<ExecutionState> |
JobMasterGateway.requestPartitionState(UUID leaderSessionID,
IntermediateDataSetID intermediateResultId,
ResultPartitionID partitionId)
Requests the current state of the partition.
|
Future<StackTrace> |
RpcTaskManagerGateway.requestStackTrace(Time timeout) |
Future<StackTraceSampleResponse> |
RpcTaskManagerGateway.requestStackTraceSample(ExecutionAttemptID executionAttemptID,
int sampleId,
int numSamples,
Time delayBetweenSamples,
int maxStackTraceDepth,
Time timeout) |
Future<BlobKey> |
RpcTaskManagerGateway.requestTaskManagerLog(Time timeout) |
Future<BlobKey> |
RpcTaskManagerGateway.requestTaskManagerStdout(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 |
---|---|
Future<Tuple2<Gateway,Success>> |
RetryingRegistration.getFuture() |
protected abstract Future<RegistrationResponse> |
RetryingRegistration.invokeRegistration(Gateway gateway,
UUID leaderId,
long timeoutMillis) |
Modifier and Type | Method and Description |
---|---|
Future<UUID> |
JobLeaderIdService.getLeaderId(JobID jobId) |
Future<Integer> |
ResourceManagerGateway.getNumberOfRegisteredTaskManagers(UUID leaderSessionId)
Gets the currently registered number of TaskManagers.
|
Future<RegistrationResponse> |
ResourceManager.registerJobManager(UUID resourceManagerLeaderId,
UUID jobManagerLeaderId,
ResourceID jobManagerResourceId,
String jobManagerAddress,
JobID jobId) |
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> |
ResourceManager.registerTaskExecutor(UUID resourceManagerLeaderId,
String taskExecutorAddress,
ResourceID taskExecutorResourceId,
SlotReport slotReport)
Register a
TaskExecutor 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 |
---|---|
protected <V> Future<V> |
RpcEndpoint.callAsync(Callable<V> callable,
Time timeout)
Execute the callable in the main thread of the underlying RPC service, returning a future for
the result of the callable.
|
<V> Future<V> |
MainThreadExecutable.callAsync(Callable<V> callable,
Time callTimeout)
Execute the callable in the main thread of the underlying RPC endpoint and return a future for
the callable result.
|
<C extends RpcGateway> |
RpcService.connect(String address,
Class<C> clazz)
Connect to a remote rpc server under the provided address.
|
<T> Future<T> |
RpcService.execute(Callable<T> callable)
Execute the given callable and return its result as a
Future . |
Future<Void> |
SelfGateway.getTerminationFuture()
Return a future which is completed when the rpc endpoint has been terminated.
|
Future<Void> |
RpcService.getTerminationFuture()
Returns a future indicating when the RPC service has been shut down.
|
Future<Void> |
RpcEndpoint.getTerminationFuture()
Return a future which is completed when the rpc endpoint has been terminated.
|
Modifier and Type | Method and Description |
---|---|
<C extends RpcGateway> |
AkkaRpcService.connect(String address,
Class<C> clazz) |
<T> Future<T> |
AkkaRpcService.execute(Callable<T> callable) |
Future<Void> |
AkkaRpcService.getTerminationFuture() |
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<Void> |
TaskManagerRunner.getTerminationFuture() |
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.
|
Modifier and Type | Method and Description |
---|---|
Future<ExecutionState> |
RpcPartitionStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID resultId,
ResultPartitionID partitionId) |
Modifier and Type | Method and Description |
---|---|
Future<ExecutionState> |
ActorGatewayPartitionProducerStateChecker.requestPartitionProducerState(JobID jobId,
IntermediateDataSetID intermediateDataSetId,
ResultPartitionID resultPartitionId) |
Modifier and Type | Method and Description |
---|---|
Future<StackTraceSample> |
StackTraceSampleCoordinator.triggerStackTraceSample(ExecutionVertex[] tasksToSample,
int numSamples,
Time delayBetweenSamples,
int maxStackTraceDepth)
Triggers a stack trace sample to all tasks.
|
Modifier and Type | Method and Description |
---|---|
protected Future<Watermark> |
WatermarkQueueEntry.getFuture() |
protected Future<Collection<OUT>> |
StreamRecordQueueEntry.getFuture() |
protected abstract Future<T> |
StreamElementQueueEntry.getFuture() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.