Uses of Class
org.apache.flink.runtime.clusterframework.ContainerSpecification

Packages that use ContainerSpecification

Package	Description
org.apache.flink.mesos.entrypoint
org.apache.flink.mesos.runtime.clusterframework
org.apache.flink.runtime.clusterframework.overlays

Uses of ContainerSpecification in org.apache.flink.mesos.entrypoint

Methods in org.apache.flink.mesos.entrypoint that return ContainerSpecification

Modifier and Type	Method and Description
static ContainerSpecification	MesosEntrypointUtils.createContainerSpec(Configuration configuration, Configuration dynamicProperties)

Methods in org.apache.flink.mesos.entrypoint with parameters of type ContainerSpecification

Modifier and Type	Method and Description
static void	MesosEntrypointUtils.applyOverlays(Configuration configuration, ContainerSpecification containerSpec) Generate a container specification as a TaskManager template.

Uses of ContainerSpecification in org.apache.flink.mesos.runtime.clusterframework

Methods in org.apache.flink.mesos.runtime.clusterframework with parameters of type ContainerSpecification

Modifier and Type

Method and Description

static akka.actor.Props

MesosFlinkResourceManager.createActorProps(Class<? extends MesosFlinkResourceManager> actorClass, Configuration flinkConfig, MesosConfiguration mesosConfig, MesosWorkerStore workerStore, LeaderRetrievalService leaderRetrievalService, MesosTaskManagerParameters taskManagerParameters, ContainerSpecification taskManagerContainerSpec, MesosArtifactResolver artifactResolver, org.slf4j.Logger log) Creates the props needed to instantiate this actor.

Constructors in org.apache.flink.mesos.runtime.clusterframework with parameters of type ContainerSpecification

Constructor and Description
LaunchableMesosWorker(MesosArtifactResolver resolver, MesosTaskManagerParameters params, ContainerSpecification containerSpec, org.apache.mesos.Protos.TaskID taskID, MesosConfiguration mesosConfiguration) Construct a launchable Mesos worker.
MesosFlinkResourceManager(Configuration flinkConfig, MesosConfiguration mesosConfig, MesosWorkerStore workerStore, LeaderRetrievalService leaderRetrievalService, MesosTaskManagerParameters taskManagerParameters, ContainerSpecification taskManagerContainerSpec, MesosArtifactResolver artifactResolver, int maxFailedTasks, int numInitialTaskManagers)
MesosResourceManager(RpcService rpcService, String resourceManagerEndpointId, ResourceID resourceId, ResourceManagerConfiguration resourceManagerConfiguration, HighAvailabilityServices highAvailabilityServices, HeartbeatServices heartbeatServices, SlotManager slotManager, MetricRegistry metricRegistry, JobLeaderIdService jobLeaderIdService, ClusterInformation clusterInformation, FatalErrorHandler fatalErrorHandler, Configuration flinkConfig, MesosServices mesosServices, MesosConfiguration mesosConfig, MesosTaskManagerParameters taskManagerParameters, ContainerSpecification taskManagerContainerSpec, String webUiUrl, JobManagerMetricGroup jobManagerMetricGroup)

Uses of ContainerSpecification in org.apache.flink.runtime.clusterframework.overlays

Methods in org.apache.flink.runtime.clusterframework.overlays with parameters of type ContainerSpecification

Modifier and Type	Method and Description
void	CompositeContainerOverlay.configure(ContainerSpecification containerConfig)
void	HadoopUserOverlay.configure(ContainerSpecification container)
void	HadoopConfOverlay.configure(ContainerSpecification container)
void	SSLStoreOverlay.configure(ContainerSpecification container)
void	ContainerOverlay.configure(ContainerSpecification containerSpecification) Configure the given container specification.
void	KeytabOverlay.configure(ContainerSpecification container)
void	FlinkDistributionOverlay.configure(ContainerSpecification container)
void	Krb5ConfOverlay.configure(ContainerSpecification container)