public class MesosSessionClusterEntrypoint extends SessionClusterEntrypoint
ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE
Constructor and Description |
---|
MesosSessionClusterEntrypoint(Configuration config,
Configuration dynamicProperties) |
Modifier and Type | Method and Description |
---|---|
protected ResourceManager<?> |
createResourceManager(Configuration configuration,
ResourceID resourceId,
RpcService rpcService,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
FatalErrorHandler fatalErrorHandler,
ClusterInformation clusterInformation,
String webInterfaceUrl,
JobManagerMetricGroup jobManagerMetricGroup) |
protected void |
initializeServices(Configuration config) |
static void |
main(String[] args) |
protected CompletableFuture<Void> |
stopClusterServices(boolean cleanupHaData) |
createDispatcher, createRestEndpoint, createSerializableExecutionGraphStore
configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getRPCPortRange, getTerminationFuture, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runCluster, shutDownAndTerminate, startCluster, startClusterComponents, stopClusterComponents
public MesosSessionClusterEntrypoint(Configuration config, Configuration dynamicProperties)
protected void initializeServices(Configuration config) throws Exception
initializeServices
in class ClusterEntrypoint
Exception
protected ResourceManager<?> createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, @Nullable String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup) throws Exception
createResourceManager
in class ClusterEntrypoint
Exception
protected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)
stopClusterServices
in class ClusterEntrypoint
public static void main(String[] args)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.