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 . |
static void |
main(String[] args) |
createSerializableExecutionGraphStore
cleanupDirectories, 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 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–2021 The Apache Software Foundation. All rights reserved.