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.

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
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, JobManagerMetricGroup jobManagerMetricGroup, String metricQueryServicePath, ArchivedExecutionGraphStore archivedExecutionGraphStore, FatalErrorHandler fatalErrorHandler, String restAddress, HistoryServerArchivist historyServerArchivist)
protected DispatcherRestEndpoint	createRestEndpoint(Configuration configuration, LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever, LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever, TransientBlobService transientBlobService, ExecutorService executor, MetricQueryServiceRetriever metricQueryServiceRetriever, LeaderElectionService leaderElectionService)
protected ArchivedExecutionGraphStore	createSerializableExecutionGraphStore(Configuration configuration, ScheduledExecutor scheduledExecutor)

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

configureFileSystems, createHaServices, createHeartbeatServices, createMetricRegistry, createResourceManager, 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

SessionClusterEntrypoint

public SessionClusterEntrypoint(Configuration configuration)

Method Detail

createSerializableExecutionGraphStore

protected ArchivedExecutionGraphStore createSerializableExecutionGraphStore(Configuration configuration,
                                                                            ScheduledExecutor scheduledExecutor)
                                                                     throws IOException

Specified by:

createSerializableExecutionGraphStore in class ClusterEntrypoint

Throws:

IOException

createRestEndpoint

protected DispatcherRestEndpoint createRestEndpoint(Configuration configuration,
                                                    LeaderGatewayRetriever<DispatcherGateway> dispatcherGatewayRetriever,
                                                    LeaderGatewayRetriever<ResourceManagerGateway> resourceManagerGatewayRetriever,
                                                    TransientBlobService transientBlobService,
                                                    ExecutorService executor,
                                                    MetricQueryServiceRetriever metricQueryServiceRetriever,
                                                    LeaderElectionService leaderElectionService)
                                             throws Exception

Specified by:

createRestEndpoint in class ClusterEntrypoint

Throws:

Exception

createDispatcher

protected Dispatcher createDispatcher(Configuration configuration,
                                      RpcService rpcService,
                                      HighAvailabilityServices highAvailabilityServices,
                                      ResourceManagerGateway resourceManagerGateway,
                                      BlobServer blobServer,
                                      HeartbeatServices heartbeatServices,
                                      JobManagerMetricGroup jobManagerMetricGroup,
                                      @Nullable
                                      String metricQueryServicePath,
                                      ArchivedExecutionGraphStore archivedExecutionGraphStore,
                                      FatalErrorHandler fatalErrorHandler,
                                      @Nullable
                                      String restAddress,
                                      HistoryServerArchivist historyServerArchivist)
                               throws Exception

Specified by:

createDispatcher in class ClusterEntrypoint

Throws:

Exception