Package | Description |
---|---|
org.apache.flink.runtime.taskexecutor | |
org.apache.flink.types |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<SerializableOptional<String>> |
TaskExecutorGateway.requestMetricQueryServiceAddress(Time timeout)
Returns the gateway of Metric Query Service on the TaskManager.
|
CompletableFuture<SerializableOptional<String>> |
TaskExecutor.requestMetricQueryServiceAddress(Time timeout) |
Modifier and Type | Method and Description |
---|---|
static <T extends Serializable> |
SerializableOptional.empty() |
<R extends Serializable> |
SerializableOptional.map(java.util.function.Function<? super T,? extends R> mapper) |
static <T extends Serializable> |
SerializableOptional.of(T value) |
static <T extends Serializable> |
SerializableOptional.ofNullable(T value) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.