public class MesosJobClusterEntrypoint extends JobClusterEntrypoint
ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE
Constructor and Description |
---|
MesosJobClusterEntrypoint(Configuration config) |
Modifier and Type | Method and Description |
---|---|
protected DefaultDispatcherResourceManagerComponentFactory |
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 MesosJobClusterEntrypoint(Configuration config)
protected void initializeServices(Configuration config) throws Exception
initializeServices
in class ClusterEntrypoint
Exception
protected CompletableFuture<Void> stopClusterServices(boolean cleanupHaData)
stopClusterServices
in class ClusterEntrypoint
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.