public class YarnSessionClusterEntrypoint extends SessionClusterEntrypoint
LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE
Constructor and Description |
---|
YarnSessionClusterEntrypoint(Configuration configuration,
String workingDirectory) |
Modifier and Type | Method and Description |
---|---|
protected ResourceManager<?> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
FatalErrorHandler fatalErrorHandler) |
protected SecurityContext |
installSecurityContext(Configuration configuration) |
static void |
main(String[] args) |
createDispatcher, createDispatcherRestEndpoint, startClusterComponents, stopClusterComponents
configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runCluster, shutDown, startCluster
public YarnSessionClusterEntrypoint(Configuration configuration, String workingDirectory)
protected SecurityContext installSecurityContext(Configuration configuration) throws Exception
installSecurityContext
in class ClusterEntrypoint
Exception
protected ResourceManager<?> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler) throws Exception
createResourceManager
in class SessionClusterEntrypoint
Exception
public static void main(String[] args)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.