org.apache.flink.runtime.entrypoint

Class StandaloneSessionClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint

org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint

All Implemented Interfaces:

FatalErrorHandler

public class StandaloneSessionClusterEntrypoint
extends SessionClusterEntrypoint

Entry point for the standalone session cluster.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

ClusterEntrypoint.ExecutionMode

Field Summary

Fields inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

EXECUTION_MODE, LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
StandaloneSessionClusterEntrypoint(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
protected ResourceManager<?>	createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, ClusterInformation clusterInformation, String webInterfaceUrl, JobManagerMetricGroup jobManagerMetricGroup)
static void	main(String[] args)

Methods inherited from class org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint

createDispatcher, createRestEndpoint, createSerializableExecutionGraphStore

Methods inherited from class org.apache.flink.runtime.entrypoint.ClusterEntrypoint

configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getRPCPortRange, getTerminationFuture, initializeServices, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runCluster, shutDownAndTerminate, startCluster, startClusterComponents, stopClusterComponents, stopClusterServices

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StandaloneSessionClusterEntrypoint

public StandaloneSessionClusterEntrypoint(Configuration configuration)

Method Detail

createResourceManager

protected ResourceManager<?> createResourceManager(Configuration configuration,
                                                   ResourceID resourceId,
                                                   RpcService rpcService,
                                                   HighAvailabilityServices highAvailabilityServices,
                                                   HeartbeatServices heartbeatServices,
                                                   MetricRegistry metricRegistry,
                                                   FatalErrorHandler fatalErrorHandler,
                                                   ClusterInformation clusterInformation,
                                                   @Nullable
                                                   String webInterfaceUrl,
                                                   JobManagerMetricGroup jobManagerMetricGroup)
                                            throws Exception

Specified by:

createResourceManager in class ClusterEntrypoint

Throws:

Exception

main

public static void main(String[] args)