org.apache.flink.util

Interface AutoCloseableAsync

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

AbstractDispatcherLeaderProcess.DispatcherGatewayService, ClusterController, DispatcherRunner, JobManagerRunner, JobMasterService, TaskManagerRunner.TaskExecutorService, TaskSlotTable<T>, WebMonitorExtension

All Known Implementing Classes:

AbstractAggregatingMetricsHandler, AbstractAsynchronousOperationHandlers.StatusHandler, AbstractAsynchronousOperationHandlers.TriggerHandler, AbstractCheckpointHandler, AbstractExecutionGraphHandler, AbstractHandler, AbstractJobManagerFileHandler, AbstractJobVertexHandler, AbstractMetricsHandler, AbstractResourceManagerHandler, AbstractRestHandler, AbstractSubtaskAttemptHandler, AbstractSubtaskHandler, AbstractTaskManagerFileHandler, ActiveResourceManager, AggregatingJobsMetricsHandler, AggregatingSubtasksMetricsHandler, AggregatingTaskManagersMetricsHandler, ApplicationClusterEntryPoint, CheckpointConfigHandler, CheckpointingStatisticsHandler, CheckpointStatisticDetailsHandler, ClientCoordinationHandler, ClusterConfigHandler, ClusterDataSetDeleteHandlers.ClusterDataSetDeleteStatusHandler, ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler, ClusterDataSetListHandler, ClusterEntrypoint, ClusterOverviewHandler, DashboardConfigHandler, DefaultDispatcherGatewayService, DefaultDispatcherRunner, Dispatcher, DispatcherJob, DispatcherResourceManagerComponent, DispatcherRestEndpoint, FencedRpcEndpoint, JarDeleteHandler, JarListHandler, JarPlanHandler, JarRunHandler, JarUploadHandler, JobAccumulatorsHandler, JobCancellationHandler, JobClusterEntrypoint, JobConfigHandler, JobDetailsHandler, JobExceptionsHandler, JobExecutionResultHandler, JobIdsHandler, JobManagerCustomLogHandler, JobManagerLogFileHandler, JobManagerLogListHandler, JobManagerMetricsHandler, JobManagerRunnerImpl, JobMaster, JobMetricsHandler, JobPlanHandler, JobsOverviewHandler, JobSubmitHandler, JobVertexAccumulatorsHandler, JobVertexBackPressureHandler, JobVertexDetailsHandler, JobVertexMetricsHandler, JobVertexTaskManagersHandler, JobVertexWatermarksHandler, KubernetesApplicationClusterEntrypoint, KubernetesSessionClusterEntrypoint, MesosJobClusterEntrypoint, MesosSessionClusterEntrypoint, MetricQueryService, MiniCluster, MiniDispatcher, MiniDispatcherRestEndpoint, PermanentlyFencedRpcEndpoint, RescalingHandlers.RescalingStatusHandler, RescalingHandlers.RescalingTriggerHandler, ResourceManager, RestClient, RestServerEndpoint, RpcEndpoint, SavepointDisposalHandlers.SavepointDisposalStatusHandler, SavepointDisposalHandlers.SavepointDisposalTriggerHandler, SavepointHandlers.SavepointStatusHandler, SavepointHandlers.SavepointTriggerHandler, SavepointHandlers.StopWithSavepointHandler, SessionClusterEntrypoint, ShutdownHandler, StandaloneApplicationClusterEntryPoint, StandaloneDispatcher, StandaloneResourceManager, StandaloneSessionClusterEntrypoint, SubtaskCurrentAttemptDetailsHandler, SubtaskExecutionAttemptAccumulatorsHandler, SubtaskExecutionAttemptDetailsHandler, SubtaskMetricsHandler, SubtasksAllAccumulatorsHandler, SubtasksTimesHandler, TaskCheckpointStatisticDetailsHandler, TaskExecutor, TaskExecutorToServiceAdapter, TaskManagerCustomLogHandler, TaskManagerDetailsHandler, TaskManagerLogFileHandler, TaskManagerLogListHandler, TaskManagerMetricsHandler, TaskManagersHandler, TaskManagerStdoutFileHandler, TaskManagerThreadDumpHandler, TaskSlot, TaskSlotTableImpl, WebMonitorEndpoint, WebMonitorExtension.EmptyWebMonitorExtension, WebSubmissionExtension, YarnApplicationClusterEntryPoint, YarnJobClusterEntrypoint, YarnSessionClusterEntrypoint

public interface AutoCloseableAsync
extends AutoCloseable

Closeable interface which allows to close a resource in a non blocking fashion.

Method Summary

Modifier and Type	Method and Description
default void	close()
CompletableFuture<Void>	closeAsync() Trigger the closing of the resource and return the corresponding close future.

Method Detail

closeAsync

CompletableFuture<Void> closeAsync()

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

Returns:

Future which is completed once the resource has been closed

close

default void close()
            throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception