Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.mesos.util | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.clusterframework.overlays |
Constructor and Description |
---|
LaunchableMesosWorker(MesosArtifactResolver resolver,
MesosTaskManagerParameters params,
ContainerSpecification containerSpec,
org.apache.mesos.Protos.TaskID taskID,
MesosConfiguration mesosConfiguration)
Construct a launchable Mesos worker.
|
MesosResourceManager(RpcService rpcService,
String resourceManagerEndpointId,
ResourceID resourceId,
HighAvailabilityServices highAvailabilityServices,
HeartbeatServices heartbeatServices,
SlotManager slotManager,
JobLeaderIdService jobLeaderIdService,
ClusterInformation clusterInformation,
FatalErrorHandler fatalErrorHandler,
Configuration flinkConfig,
MesosServices mesosServices,
MesosConfiguration mesosConfig,
MesosTaskManagerParameters taskManagerParameters,
ContainerSpecification taskManagerContainerSpec,
String webUiUrl,
ResourceManagerMetricGroup resourceManagerMetricGroup) |
Modifier and Type | Method and Description |
---|---|
static ContainerSpecification |
MesosUtils.createContainerSpec(Configuration flinkConfiguration) |
Modifier and Type | Method and Description |
---|---|
static void |
MesosUtils.applyOverlays(Configuration configuration,
ContainerSpecification containerSpec)
Generate a container specification as a TaskManager template.
|
Modifier and Type | Method and Description |
---|---|
static ContainerSpecification |
ContainerSpecification.from(Configuration flinkConfiguration) |
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 |
UserLibOverlay.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) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.