public class ApplicationClusterEntryPoint extends ClusterEntrypoint
main()
method of the application is run on the cluster.ClusterEntrypoint.ExecutionMode, ClusterEntrypoint.ShutdownBehaviour
INTERNAL_CLUSTER_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(ClusterEntrypoint.ShutdownBehaviour shutdownBehaviour)
Clean up of temporary directories created by the
ClusterEntrypoint . |
protected static void |
configureExecution(Configuration configuration,
PackagedProgram program) |
protected DispatcherResourceManagerComponentFactory |
createDispatcherResourceManagerComponentFactory(Configuration configuration) |
protected ExecutionGraphInfoStore |
createSerializableExecutionGraphStore(Configuration configuration,
ScheduledExecutor scheduledExecutor) |
closeAsync, createHaServices, createHeartbeatServices, createMetricRegistry, getRestPort, getRpcPort, getRPCPortRange, getTerminationFuture, initializeServices, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runClusterEntrypoint, startCluster, stopClusterServices, supportsReactiveMode
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 ExecutionGraphInfoStore createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)
createSerializableExecutionGraphStore
in class ClusterEntrypoint
protected static void configureExecution(Configuration configuration, PackagedProgram program) throws Exception
Exception
protected void cleanupDirectories(ClusterEntrypoint.ShutdownBehaviour shutdownBehaviour) throws IOException
ClusterEntrypoint
ClusterEntrypoint
.cleanupDirectories
in class ClusterEntrypoint
shutdownBehaviour
- specifying the shutdown behaviourIOException
- if the temporary directories could not be cleaned upCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.