org.apache.flink.runtime.taskexecutor

Class TaskExecutorToServiceAdapter

java.lang.Object

org.apache.flink.runtime.taskexecutor.TaskExecutorToServiceAdapter

All Implemented Interfaces:

AutoCloseable, TaskManagerRunner.TaskExecutorService, AutoCloseableAsync

public class TaskExecutorToServiceAdapter
extends Object
implements TaskManagerRunner.TaskExecutorService

Simple adapter for TaskExecutor to adapt to TaskManagerRunner.TaskExecutorService.

Method Summary

Modifier and Type	Method and Description
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.
static TaskExecutorToServiceAdapter	createFor(TaskExecutor taskExecutor)
CompletableFuture<Void>	getTerminationFuture()
void	start()

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.util.AutoCloseableAsync

close

Method Detail

start

public void start()

Specified by:

start in interface TaskManagerRunner.TaskExecutorService

getTerminationFuture

public CompletableFuture<Void> getTerminationFuture()

Specified by:

getTerminationFuture in interface TaskManagerRunner.TaskExecutorService

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from interface: AutoCloseableAsync

Trigger the closing of the resource and return the corresponding close future.

Specified by:

closeAsync in interface AutoCloseableAsync

Returns:

Future which is completed once the resource has been closed

createFor

public static TaskExecutorToServiceAdapter createFor(TaskExecutor taskExecutor)