org.apache.flink.runtime.rpc

Interface FencedMainThreadExecutable

All Superinterfaces:

MainThreadExecutable

All Known Implementing Classes:

FencedAkkaInvocationHandler

public interface FencedMainThreadExecutable
extends MainThreadExecutable

Extended MainThreadExecutable interface which allows to run unfenced runnables in the main thread.

Method Summary

Modifier and Type	Method and Description
<V> CompletableFuture<V>	callAsyncWithoutFencing(Callable<V> callable, Time timeout) Run the given callable in the main thread without attaching a fencing token.
void	runAsyncWithoutFencing(Runnable runnable) Run the given runnable in the main thread without attaching a fencing token.

Methods inherited from interface org.apache.flink.runtime.rpc.MainThreadExecutable

callAsync, runAsync, scheduleRunAsync

Method Detail

runAsyncWithoutFencing

void runAsyncWithoutFencing(Runnable runnable)

Run the given runnable in the main thread without attaching a fencing token.

Parameters:

runnable - to run in the main thread without validating the fencing token.

callAsyncWithoutFencing

<V> CompletableFuture<V> callAsyncWithoutFencing(Callable<V> callable,
                                                 Time timeout)

Run the given callable in the main thread without attaching a fencing token.

Type Parameters:

V - type of the callable result

Parameters:

callable - to run in the main thread without validating the fencing token.

timeout - for the operation

Returns:

Future containing the callable result