org.apache.flink.mesos.entrypoint

Class MesosSessionClusterEntrypoint

java.lang.Object

org.apache.flink.runtime.entrypoint.ClusterEntrypoint

org.apache.flink.runtime.entrypoint.SessionClusterEntrypoint

org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

All Implemented Interfaces:

FatalErrorHandler

public class MesosSessionClusterEntrypoint
extends SessionClusterEntrypoint

Entry point for Mesos session clusters.

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
MesosSessionClusterEntrypoint(Configuration config, Configuration dynamicProperties)

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)
protected void	initializeServices(Configuration config)
static void	main(String[] args)
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.SessionClusterEntrypoint

createDispatcher, createDispatcherRestEndpoint

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

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

MesosSessionClusterEntrypoint

public MesosSessionClusterEntrypoint(Configuration config,
                                     Configuration dynamicProperties)

Method Detail

initializeServices

protected void initializeServices(Configuration config)
                           throws Exception

Overrides:

initializeServices in class ClusterEntrypoint

Throws:

Exception

startClusterComponents

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

Overrides:

startClusterComponents in class SessionClusterEntrypoint

Throws:

Exception

createResourceManager

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

Specified by:

createResourceManager in class SessionClusterEntrypoint

Throws:

Exception

stopClusterComponents

protected void stopClusterComponents(boolean cleanupHaData)
                              throws Exception

Overrides:

stopClusterComponents in class SessionClusterEntrypoint

Throws:

Exception

main

public static void main(String[] args)