org.apache.flink.streaming.runtime.tasks

Class StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor

java.lang.Object

org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor

All Implemented Interfaces:

StreamTaskActionExecutor

Enclosing interface:

StreamTaskActionExecutor

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).

@Deprecated
public static class StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor
extends Object
implements StreamTaskActionExecutor

A StreamTaskActionExecutor that synchronizes every operation on the provided mutex.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor

StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor

Field Summary

Fields inherited from interface org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor

IMMEDIATE

Constructor Summary

Constructors

Constructor and Description
SynchronizedStreamTaskActionExecutor(Object mutex) Deprecated.

Method Summary

Modifier and Type	Method and Description
<R> R	call(Callable<R> callable) Deprecated.
Object	getMutex() Deprecated.
void	run(RunnableWithException runnable) Deprecated.
<E extends Throwable> void	runThrowing(ThrowingRunnable<E> runnable) Deprecated.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor

synchronizedExecutor, synchronizedExecutor

Constructor Detail

SynchronizedStreamTaskActionExecutor

public SynchronizedStreamTaskActionExecutor(Object mutex)

Deprecated.

Method Detail

run

public void run(RunnableWithException runnable)
         throws Exception

Deprecated.

Specified by:

run in interface StreamTaskActionExecutor

Throws:

Exception

runThrowing

public <E extends Throwable> void runThrowing(ThrowingRunnable<E> runnable)
                                       throws E extends Throwable

Deprecated.

Specified by:

runThrowing in interface StreamTaskActionExecutor

Throws:

E extends Throwable

call

public <R> R call(Callable<R> callable)
           throws Exception

Deprecated.

Specified by:

call in interface StreamTaskActionExecutor

Throws:

Exception

getMutex

public Object getMutex()

Deprecated.

Returns:

an object used for mutual exclusion of all operations that involve data and state mutation. (a.k.a. checkpoint lock).