public class ApplicationClusterEntryPoint extends ClusterEntrypoint
main()
method of the application is run on the cluster.ClusterEntrypoint.ExecutionMode
EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE
Modifier | Constructor and Description |
---|---|
protected |
ApplicationClusterEntryPoint(Configuration configuration,
PackagedProgram program,
ResourceManagerFactory<?> resourceManagerFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
cleanupDirectories()
Clean up of temporary directories created by the
ClusterEntrypoint . |
protected static void |
configureExecution(Configuration configuration,
PackagedProgram program) |
protected DispatcherResourceManagerComponentFactory |
createDispatcherResourceManagerComponentFactory(Configuration configuration) |
protected ArchivedExecutionGraphStore |
createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRPCPortRange, getTerminationFuture, initializeServices, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close
protected ApplicationClusterEntryPoint(Configuration configuration, PackagedProgram program, ResourceManagerFactory<?> resourceManagerFactory)
protected DispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(Configuration configuration)
createDispatcherResourceManagerComponentFactory
in class ClusterEntrypoint
protected ArchivedExecutionGraphStore createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
createSerializableExecutionGraphStore
in class ClusterEntrypoint
protected static void configureExecution(Configuration configuration, PackagedProgram program) throws Exception
Exception
protected void cleanupDirectories() throws IOException
ClusterEntrypoint
ClusterEntrypoint
.cleanupDirectories
in class ClusterEntrypoint
IOException
- if the temporary directories could not be cleaned upCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.