Modifier and Type | Field and Description |
---|---|
ScheduledExecutorService |
executorService |
BlobLibraryCacheManager |
libraryCacheManager |
RestartStrategyFactory |
restartStrategyFactory |
Time |
rpcAskTimeout |
Constructor and Description |
---|
JobManagerServices(ScheduledExecutorService executorService,
BlobLibraryCacheManager libraryCacheManager,
RestartStrategyFactory restartStrategyFactory,
Time rpcAskTimeout) |
Modifier and Type | Method and Description |
---|---|
static JobManagerServices |
fromConfiguration(Configuration config,
HighAvailabilityServices haServices) |
void |
shutdown()
This method makes sure all services are closed or shut down, even when an exception occurred
in the shutdown of one component.
|
public final ScheduledExecutorService executorService
public final BlobLibraryCacheManager libraryCacheManager
public final RestartStrategyFactory restartStrategyFactory
public final Time rpcAskTimeout
public JobManagerServices(ScheduledExecutorService executorService, BlobLibraryCacheManager libraryCacheManager, RestartStrategyFactory restartStrategyFactory, Time rpcAskTimeout)
public void shutdown() throws Exception
This method makes sure all services are closed or shut down, even when an exception occurred in the shutdown of one component. The first encountered exception is thrown, with successive exceptions added as suppressed exceptions.
Exception
- The first Exception encountered during shutdown.public static JobManagerServices fromConfiguration(Configuration config, HighAvailabilityServices haServices) throws Exception
Exception
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.