Modifier and Type | Method and Description |
---|---|
Future<CompletedCheckpoint> |
PendingCheckpoint.getCompletionFuture()
Returns the completion future.
|
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.
|
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.
|
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> 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.
|
<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 | 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 | Method and Description |
---|---|
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 |
---|---|
Future<SimpleSlot> |
SlotProvider.allocateSlot(ScheduledUnit task,
boolean allowQueued)
Allocating slot with specific requirement.
|
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<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–2017 The Apache Software Foundation. All rights reserved.