public class MesosSessionClusterEntrypoint extends SessionClusterEntrypoint
ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE
Constructor and Description |
---|
MesosSessionClusterEntrypoint(Configuration config,
Configuration dynamicProperties) |
Modifier and Type | Method and Description |
---|---|
protected DispatcherResourceManagerComponentFactory<?> |
createDispatcherResourceManagerComponentFactory(Configuration configuration) |
protected void |
initializeServices(Configuration config) |
static void |
main(String[] args) |
protected CompletableFuture<Void> |
stopClusterServices(boolean cleanupHaData) |
createSerializableExecutionGraphStore
closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRPCPortRange, getTerminationFuture, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
public MesosSessionClusterEntrypoint(Configuration config, Configuration dynamicProperties)
protected void initializeServices(Configuration config) throws Exception
initializeServices
in class ClusterEntrypoint
Exception
protected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)
stopClusterServices
in class ClusterEntrypoint
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.