org.apache.flink.runtime.entrypoint

Class SessionClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint

All Implemented Interfaces:

FatalErrorHandler

Direct Known Subclasses:

MesosSessionClusterEntrypoint, StandaloneSessionClusterEntrypoint, YarnSessionClusterEntrypoint

public abstract class SessionClusterEntrypoint
extends ClusterEntrypoint

Base class for session cluster entry points.

Field Summary

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

LOG, RUNTIME_FAILURE_RETURN_CODE, STARTUP_FAILURE_RETURN_CODE, SUCCESS_RETURN_CODE

Constructor Summary

Constructors

Constructor and Description
SessionClusterEntrypoint(Configuration configuration)

Method Summary

Modifier and Type	Method and Description
protected Dispatcher	createDispatcher(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, ResourceManagerGateway resourceManagerGateway, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler, Optional<String> restAddress)
protected DispatcherRestEndpoint	createDispatcherRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, Executor executor)
protected abstract ResourceManager<?>	createResourceManager(Configuration configuration, ResourceID resourceId, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry, FatalErrorHandler fatalErrorHandler)
protected void	startClusterComponents(Configuration configuration, RpcService rpcService, HighAvailabilityServices highAvailabilityServices, BlobServer blobServer, HeartbeatServices heartbeatServices, MetricRegistry metricRegistry)
protected void	stopClusterComponents(boolean cleanupHaData)

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

configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createRpcService, getTerminationFuture, initializeServices, installSecurityContext, loadConfiguration, onFatalError, parseArguments, runCluster, shutDown, startCluster

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionClusterEntrypoint

public SessionClusterEntrypoint(Configuration configuration)

Method Detail

startClusterComponents

protected void startClusterComponents(Configuration configuration,
                                      RpcService rpcService,
                                      HighAvailabilityServices highAvailabilityServices,
                                      BlobServer blobServer,
                                      HeartbeatServices heartbeatServices,
                                      MetricRegistry metricRegistry)
                               throws Exception

Specified by:

startClusterComponents in class ClusterEntrypoint

Throws:

Exception

stopClusterComponents

protected void stopClusterComponents(boolean cleanupHaData)
                              throws Exception

Overrides:

stopClusterComponents in class ClusterEntrypoint

Throws:

Exception

createDispatcherRestEndpoint

protected DispatcherRestEndpoint createDispatcherRestEndpoint(Configuration configuration,
                                                              LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
                                                              Executor executor)
                                                       throws Exception

Throws:

Exception

createDispatcher

protected Dispatcher createDispatcher(Configuration configuration,
                                      RpcService rpcService,
                                      HighAvailabilityServices highAvailabilityServices,
                                      ResourceManagerGateway resourceManagerGateway,
                                      BlobServer blobServer,
                                      HeartbeatServices heartbeatServices,
                                      MetricRegistry metricRegistry,
                                      FatalErrorHandler fatalErrorHandler,
                                      Optional<String> restAddress)
                               throws Exception

Throws:

Exception

createResourceManager

protected abstract ResourceManager<?> createResourceManager(Configuration configuration,
                                                            ResourceID resourceId,
                                                            RpcService rpcService,
                                                            HighAvailabilityServices highAvailabilityServices,
                                                            HeartbeatServices heartbeatServices,
                                                            MetricRegistry metricRegistry,
                                                            FatalErrorHandler fatalErrorHandler)
                                                     throws Exception

Throws:

Exception