Package org.apache.flink.util

Interface AutoCloseableAsync

All Superinterfaces:

AutoCloseable

All Known Subinterfaces:

AbstractDispatcherLeaderProcess.DispatcherGatewayService, ClusterController, DispatcherRunner, GatewayController, JobManagerRunner, JobMasterService, JobMasterServiceProcess, ResourceManagerService, RestService, RpcService, SchedulerNG, TaskManagerRunner.TaskExecutorService, TaskSlotTable<T>, WebMonitorExtension

All Known Implementing Classes:

AbstractAccessExecutionGraphHandler, AbstractAggregatingMetricsHandler, AbstractAsynchronousOperationHandlers.StatusHandler, AbstractAsynchronousOperationHandlers.TriggerHandler, AbstractCheckpointHandler, AbstractCheckpointStatsHandler, AbstractDispatcherLeaderProcess, AbstractExecutionGraphHandler, AbstractHandler, AbstractJobManagerFileHandler, AbstractJobVertexHandler, AbstractMetricsHandler, AbstractOperationHandler, AbstractResourceManagerHandler, AbstractRestHandler, AbstractSqlGatewayRestHandler, AbstractSubtaskAttemptHandler, AbstractSubtaskHandler, AbstractTaskManagerFileHandler, ActiveResourceManager, AdaptiveBatchScheduler, AdaptiveScheduler, AggregatingJobsMetricsHandler, AggregatingSubtasksMetricsHandler, AggregatingTaskManagersMetricsHandler, ApplicationClusterEntryPoint, CancelOperationHandler, CheckpointConfigHandler, CheckpointHandlers.CheckpointStatusHandler, CheckpointHandlers.CheckpointTriggerHandler, CheckpointingStatisticsHandler, CheckpointResourcesCleanupRunner, CheckpointsCleaner, CheckpointStatisticDetailsHandler, ClientCoordinationHandler, CloseOperationHandler, CloseSessionHandler, ClusterConfigHandler, ClusterDataSetDeleteHandlers.ClusterDataSetDeleteStatusHandler, ClusterDataSetDeleteHandlers.ClusterDataSetDeleteTriggerHandler, ClusterDataSetListHandler, ClusterEntrypoint, ClusterOverviewHandler, CompletedOperationCache, CompleteStatementHandler, ConfigureSessionHandler, CreateEmbeddedSchedulerWorkflowHandler, DashboardConfigHandler, DefaultDispatcherGatewayService, DefaultDispatcherRunner, DefaultJobMasterServiceProcess, DefaultScheduler, DeleteEmbeddedSchedulerWorkflowHandler, Dispatcher, DispatcherOperationCaches, DispatcherResourceManagerComponent, DispatcherRestEndpoint, ExecuteStatementHandler, FencedRpcEndpoint, FetchResultsHandler, GetApiVersionHandler, GetInfoHandler, GetOperationStatusHandler, GetSessionConfigHandler, JarDeleteHandler, JarListHandler, JarPlanHandler, JarRunHandler, JarUploadHandler, JobAccumulatorsHandler, JobCancellationHandler, JobClientHeartbeatHandler, JobClusterEntrypoint, JobConfigHandler, JobDetailsHandler, JobDispatcherLeaderProcess, JobExceptionsHandler, JobExecutionResultHandler, JobIdsHandler, JobManagerCustomLogHandler, JobManagerEnvironmentHandler, JobManagerJobConfigurationHandler, JobManagerJobEnvironmentHandler, JobManagerLogFileHandler, JobManagerLogListHandler, JobManagerMetricsHandler, JobManagerOperatorMetricsHandler, JobManagerProfilingFileHandler, JobManagerProfilingHandler, JobManagerProfilingListHandler, JobManagerThreadDumpHandler, JobMaster, JobMasterServiceLeadershipRunner, JobMasterServiceProcess.WaitingForLeadership, JobMetricsHandler, JobPlanHandler, JobResourceRequirementsHandler, JobResourceRequirementsUpdateHandler, JobsOverviewHandler, JobStatusHandler, JobSubmitHandler, JobVertexAccumulatorsHandler, JobVertexBackPressureHandler, JobVertexDetailsHandler, JobVertexFlameGraphHandler, JobVertexMetricsHandler, JobVertexTaskManagersHandler, JobVertexWatermarksHandler, KubernetesApplicationClusterEntrypoint, KubernetesSessionClusterEntrypoint, MetricQueryService, MetricRegistryImpl, MiniCluster, MiniDispatcher, MiniDispatcherRestEndpoint, OpenSessionHandler, PekkoRpcService, RefreshMaterializedTableHandler, RescalingHandlers.RescalingStatusHandler, RescalingHandlers.RescalingTriggerHandler, ResourceManager, ResourceManagerServiceImpl, RestClient, RestServerEndpoint, ResumeEmbeddedSchedulerWorkflowHandler, RpcEndpoint, SavepointDisposalHandlers.SavepointDisposalStatusHandler, SavepointDisposalHandlers.SavepointDisposalTriggerHandler, SavepointHandlers.SavepointStatusHandler, SavepointHandlers.SavepointTriggerHandler, SavepointHandlers.StopWithSavepointHandler, SchedulerBase, SessionClusterEntrypoint, SessionDispatcherLeaderProcess, ShutdownHandler, SqlGatewayRestEndpoint, StandaloneApplicationClusterEntryPoint, StandaloneDispatcher, StandaloneResourceManager, StandaloneSessionClusterEntrypoint, StoppedDispatcherLeaderProcess, SubtaskCurrentAttemptDetailsHandler, SubtaskExecutionAttemptAccumulatorsHandler, SubtaskExecutionAttemptDetailsHandler, SubtaskMetricsHandler, SubtasksAllAccumulatorsHandler, SubtasksTimesHandler, SuspendEmbeddedSchedulerWorkflowHandler, TaskCheckpointStatisticDetailsHandler, TaskExecutor, TaskExecutorToServiceAdapter, TaskManagerCustomLogHandler, TaskManagerDetailsHandler, TaskManagerLogFileHandler, TaskManagerLogListHandler, TaskManagerMetricsHandler, TaskManagerProfilingFileHandler, TaskManagerProfilingHandler, TaskManagerProfilingListHandler, TaskManagersHandler, TaskManagerStdoutFileHandler, TaskManagerThreadDumpHandler, TaskSlot, TaskSlotTableImpl, TriggerSessionHeartbeatHandler, 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	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