@Internal public interface StreamTaskActionExecutor
Runnable
, ThrowingRunnable
, or Callable
.
Intended to customize execution in sub-types of StreamTask
,
e.g. synchronization in SourceStreamTask
.Modifier and Type | Interface and Description |
---|---|
static class |
StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor
Deprecated.
this class should only be used in
SourceStreamTask which exposes the checkpoint lock as part of Public API.
During transitional period it is used in StreamTask (until StreamTask.getCheckpointLock()
is pushed down to SourceStreamTask ). |
Modifier and Type | Field and Description |
---|---|
static StreamTaskActionExecutor |
IMMEDIATE |
Modifier and Type | Method and Description |
---|---|
<R> R |
call(Callable<R> callable) |
void |
run(RunnableWithException runnable) |
<E extends Throwable> |
runThrowing(ThrowingRunnable<E> runnable) |
static StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor |
synchronizedExecutor()
Returns an ExecutionDecorator that synchronizes each invocation.
|
static StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor |
synchronizedExecutor(Object mutex)
Returns an ExecutionDecorator that synchronizes each invocation on a given object.
|
static final StreamTaskActionExecutor IMMEDIATE
void run(RunnableWithException runnable) throws Exception
Exception
<E extends Throwable> void runThrowing(ThrowingRunnable<E> runnable) throws E extends Throwable
E extends Throwable
static StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor synchronizedExecutor()
static StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor synchronizedExecutor(Object mutex)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.