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 forTaskExecutor
to adapt toTaskManagerRunner.TaskExecutorService
.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method 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 interfaceTaskManagerRunner.TaskExecutorService
-
getTerminationFuture
public CompletableFuture<Void> getTerminationFuture()
- Specified by:
getTerminationFuture
in interfaceTaskManagerRunner.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 interfaceAutoCloseableAsync
- Returns:
- Future which is completed once the resource has been closed
-
createFor
public static TaskExecutorToServiceAdapter createFor(TaskExecutor taskExecutor)
-
-