public class YarnJobClusterEntrypoint extends JobClusterEntrypoint
ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE
Constructor and Description |
---|
YarnJobClusterEntrypoint(Configuration configuration,
String workingDirectory) |
Modifier and Type | Method and Description |
---|---|
protected DispatcherResourceManagerComponentFactory<?> |
createDispatcherResourceManagerComponentFactory(Configuration configuration) |
protected String |
getRPCPortRange(Configuration configuration)
Returns the port range for the common
RpcService . |
protected SecurityContext |
installSecurityContext(Configuration configuration) |
static void |
main(String[] args) |
createSerializableExecutionGraphStore
closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public YarnJobClusterEntrypoint(Configuration configuration, String workingDirectory)
protected SecurityContext installSecurityContext(Configuration configuration) throws Exception
installSecurityContext
in class ClusterEntrypoint
Exception
protected String getRPCPortRange(Configuration configuration)
ClusterEntrypoint
RpcService
.getRPCPortRange
in class ClusterEntrypoint
configuration
- to extract the port range fromRpcService
protected DispatcherResourceManagerComponentFactory<?> createDispatcherResourceManagerComponentFactory(Configuration configuration)
createDispatcherResourceManagerComponentFactory
in class ClusterEntrypoint
public static void main(String[] args)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.