Package | Description |
---|---|
org.apache.flink.connector.file.src.util | |
org.apache.flink.runtime.concurrent | |
org.apache.flink.runtime.memory | |
org.apache.flink.runtime.operators.coordination | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
org.apache.flink.streaming.runtime.tasks.mailbox | |
org.apache.flink.util | |
org.apache.flink.util.function |
Modifier and Type | Method and Description |
---|---|
static void |
Utils.doWithCleanupOnException(Closeable toCleanUp,
ThrowingRunnable<IOException> code)
Runs the given
Runnable . |
Modifier and Type | Class and Description |
---|---|
class |
FutureTaskWithException<V>
FutureTask that also implements RunnableWithException . |
Constructor and Description |
---|
OpaqueMemoryResource(T resourceHandle,
long size,
ThrowingRunnable<Exception> disposer) |
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<Void> |
ComponentClosingUtils.closeAsyncWithTimeout(String componentName,
ThrowingRunnable<Exception> closingSequence,
java.time.Duration closeTimeout)
Close a component with a timeout.
|
Modifier and Type | Method and Description |
---|---|
default void |
MailboxExecutor.execute(ThrowingRunnable<? extends Exception> command,
String description)
Executes the given command at some time in the future in the mailbox thread.
|
void |
MailboxExecutor.execute(ThrowingRunnable<? extends Exception> command,
String descriptionFormat,
Object... descriptionArgs)
Executes the given command at some time in the future in the mailbox thread.
|
Modifier and Type | Method and Description |
---|---|
<E extends Throwable> |
StreamTaskActionExecutor.runThrowing(ThrowingRunnable<E> runnable) |
<E extends Throwable> |
StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor.runThrowing(ThrowingRunnable<E> runnable)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
MailboxExecutorImpl.execute(ThrowingRunnable<? extends Exception> command,
String descriptionFormat,
Object... descriptionArgs) |
Constructor and Description |
---|
Mail(ThrowingRunnable<? extends Exception> runnable,
int priority,
StreamTaskActionExecutor actionExecutor,
String descriptionFormat,
Object... descriptionArgs) |
Mail(ThrowingRunnable<? extends Exception> runnable,
int priority,
String descriptionFormat,
Object... descriptionArgs) |
Modifier and Type | Method and Description |
---|---|
<E extends Exception> |
OptionalConsumer.ifNotPresent(ThrowingRunnable<E> r) |
static <E extends Throwable> |
LambdaUtil.withContextClassLoader(ClassLoader cl,
ThrowingRunnable<E> r)
Runs the given runnable with the given ClassLoader as the thread's
context class loader . |
Modifier and Type | Interface and Description |
---|---|
interface |
RunnableWithException
Similar to a
Runnable , this interface is used to capture a block of code to be executed. |
Modifier and Type | Method and Description |
---|---|
static Runnable |
ThrowingRunnable.unchecked(ThrowingRunnable<?> throwingRunnable)
Converts a
ThrowingRunnable into a Runnable which throws all checked
exceptions as unchecked. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.