Class Hierarchy
- java.lang.Object
- java.util.concurrent.CompletableFuture<T> (implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<V>)
- org.apache.flink.util.concurrent.FutureUtils.ConjunctFuture<T>
- org.apache.flink.util.concurrent.Executors
- org.apache.flink.util.concurrent.ExecutorThreadFactory (implements java.util.concurrent.ThreadFactory)
- org.apache.flink.util.concurrent.ExecutorThreadFactory.Builder
- org.apache.flink.util.concurrent.ExponentialBackoffRetryStrategy (implements org.apache.flink.util.concurrent.RetryStrategy)
- org.apache.flink.util.concurrent.FixedRetryStrategy (implements org.apache.flink.util.concurrent.RetryStrategy)
- org.apache.flink.util.concurrent.FutureUtils
- org.apache.flink.util.concurrent.IgnoreShutdownRejectedExecutionHandler (implements java.util.concurrent.RejectedExecutionHandler)
- org.apache.flink.util.concurrent.IncrementalDelayRetryStrategy (implements org.apache.flink.util.concurrent.RetryStrategy)
- org.apache.flink.util.concurrent.NeverCompleteFuture (implements java.util.concurrent.ScheduledFuture<V>)
- org.apache.flink.util.concurrent.ScheduledExecutorServiceAdapter (implements org.apache.flink.util.concurrent.ScheduledExecutor)
- org.apache.flink.util.concurrent.SeparateThreadExecutor (implements java.util.concurrent.Executor)
- org.apache.flink.util.concurrent.ThreadUtils
- java.lang.Throwable (implements java.io.Serializable)
- java.lang.Exception
- org.apache.flink.util.concurrent.FutureUtils.RetryException
- java.lang.Exception
- java.util.concurrent.CompletableFuture<T> (implements java.util.concurrent.CompletionStage<T>, java.util.concurrent.Future<V>)
Interface Hierarchy
- java.util.function.Consumer<T>
- org.apache.flink.util.concurrent.FutureConsumerWithException<T,E>
- java.util.concurrent.Executor
- org.apache.flink.util.concurrent.ScheduledExecutor
- org.apache.flink.util.concurrent.RetryStrategy