Package | Description |
---|---|
org.apache.flink.runtime.concurrent | |
org.apache.flink.runtime.concurrent.impl | |
org.apache.flink.streaming.api.operators.async.queue |
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
Future<Void> |
FlinkFuture.thenAccept(AcceptFunction<? super T> acceptFunction) |
Future<Void> |
FlinkFuture.thenAcceptAsync(AcceptFunction<? super T> acceptFunction,
Executor executor) |
Modifier and Type | Method and Description |
---|---|
void |
StreamElementQueueEntry.onComplete(AcceptFunction<StreamElementQueueEntry<T>> completeFunction,
Executor executor)
Register the given complete function to be called once this queue entry has been completed.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.