public class KubernetesSessionClusterEntrypoint extends SessionClusterEntrypoint
ClusterEntrypoint.ExecutionMode, ClusterEntrypoint.ShutdownBehaviour
INTERNAL_CLUSTER_EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE
Constructor and Description |
---|
KubernetesSessionClusterEntrypoint(Configuration configuration) |
Modifier and Type | Method and Description |
---|---|
protected DispatcherResourceManagerComponentFactory |
createDispatcherResourceManagerComponentFactory(Configuration configuration) |
static void |
main(String[] args) |
createSerializableExecutionGraphStore
cleanupDirectories, 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
public KubernetesSessionClusterEntrypoint(Configuration configuration)
protected DispatcherResourceManagerComponentFactory createDispatcherResourceManagerComponentFactory(Configuration configuration)
createDispatcherResourceManagerComponentFactory
in class ClusterEntrypoint
public static void main(String[] args)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.