public class YarnJobClusterEntrypoint extends JobClusterEntrypoint
ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE
Constructor and Description |
---|
YarnJobClusterEntrypoint(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected DefaultDispatcherResourceManagerComponentFactory |
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)
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 DefaultDispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(Configuration configuration) throws IOException
createDispatcherResourceManagerComponentFactory
in class ClusterEntrypoint
IOException
public static void main(String[] args)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.