A B C D E F G H I L M N O P R S T U V W Z

A

AbstractMesosServices - Class in org.apache.flink.mesos.runtime.clusterframework.services

An abstract implementation of MesosServices.

AbstractMesosServices(ActorSystem, MesosArtifactServer) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices

acceptOffers(AcceptOffers) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Accept offers as advised by the launch coordinator.

acceptOffers(AcceptOffers) - Method in interface org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerActions

Accept the given offers as advised by the launch coordinator.

AcceptOffers - Class in org.apache.flink.mesos.scheduler.messages

Local message sent by the launch coordinator to the scheduler to accept offers.

AcceptOffers(String, Collection<Protos.OfferID>, Collection<Protos.Offer.Operation>) - Constructor for class org.apache.flink.mesos.scheduler.messages.AcceptOffers

AcceptOffers(String, Collection<Protos.OfferID>, Collection<Protos.Offer.Operation>, Protos.Filters) - Constructor for class org.apache.flink.mesos.scheduler.messages.AcceptOffers

addFile(File, String) - Method in class org.apache.flink.mesos.util.MesosArtifactServer

Adds a file to the artifact server.

addPath(Path, Path) - Method in class org.apache.flink.mesos.util.MesosArtifactServer

Adds a path to the artifact server.

applyOverlays(Configuration, ContainerSpecification) - Static method in class org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

Generate a container specification as a TaskManager template.

ARTIFACT_SERVER_PORT - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

The config parameter defining the Mesos artifact server port to use.

ARTIFACT_SERVER_SSL_ENABLED - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

Config parameter to override SSL support for the Artifact Server.

B

baseURL() - Method in class org.apache.flink.mesos.util.MesosArtifactServer

bootstrapCommand() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the bootstrap command.

build() - Method in interface org.apache.flink.mesos.scheduler.TaskSchedulerBuilder

Build a Fenzo task scheduler.

buildDockerParameters(Option<String>) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

buildUris(Option<String>) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Build a list of URIs for providing custom artifacts to Mesos tasks.

buildVolumes(Option<String>) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Used to build volume specs for mesos.

C

channelRead0(ChannelHandlerContext, Object) - Method in class org.apache.flink.mesos.util.MesosArtifactServer.UnknownFileHandler

channelRead0(ChannelHandlerContext, RoutedRequest) - Method in class org.apache.flink.mesos.util.MesosArtifactServer.VirtualFileServerHandler

clearStateAsync() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

close(boolean) - Method in class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices

close(boolean) - Method in interface org.apache.flink.mesos.runtime.clusterframework.services.MesosServices

Closes all state maintained by the mesos services implementation.

close(boolean) - Method in class org.apache.flink.mesos.runtime.clusterframework.services.StandaloneMesosServices

close(boolean) - Method in class org.apache.flink.mesos.runtime.clusterframework.services.ZooKeeperMesosServices

command() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the command.

Connected - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when the scheduler becomes "connected" to the master.

Connected() - Constructor for class org.apache.flink.mesos.scheduler.messages.Connected

constraints() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the placement constraints.

containeredParameters() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the common containered parameters.

containerImageName() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the container image name.

containerType() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the container type (Mesos or Docker).

containerVolumes() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the container volumes string.

cpuCores() - Method in class org.apache.flink.mesos.scheduler.Offer

cpus() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the CPU units to use for the TaskManager process.

cpus(double) - Static method in class org.apache.flink.mesos.Utils

Construct a cpu resource.

cpus(String, double) - Static method in class org.apache.flink.mesos.Utils

Construct a cpu resource.

create(Configuration) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Create the Mesos TaskManager parameters.

createActorProps(Class<? extends MesosFlinkResourceManager>, Configuration, MesosConfiguration, MesosWorkerStore, LeaderRetrievalService, MesosTaskManagerParameters, ContainerSpecification, MesosArtifactResolver, Logger) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Creates the props needed to instantiate this actor.

createConnectionMonitor() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

createConnectionMonitor() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

createContainerSpec(Configuration, Configuration) - Static method in class org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

createDispatcherResourceManagerComponentFactory(Configuration) - Method in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint

createDispatcherResourceManagerComponentFactory(Configuration) - Method in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

createDriver(Scheduler, boolean) - Method in class org.apache.flink.mesos.util.MesosConfiguration

Create the Mesos scheduler driver based on this configuration.

createLaunchCoordinator() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

createLaunchCoordinator(SchedulerDriver, ActorRef) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

createMesosSchedulerConfiguration(Configuration, String) - Static method in class org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

Loads and validates the Mesos scheduler configuration.

createMesosServices(Configuration, String) - Static method in class org.apache.flink.mesos.runtime.clusterframework.services.MesosServicesUtils

Creates a MesosServices instance depending on the high availability settings.

createMesosWorkerStore(Configuration, Executor) - Method in interface org.apache.flink.mesos.runtime.clusterframework.services.MesosServices

Creates a MesosWorkerStore which is used to persist mesos worker in high availability mode.

createMesosWorkerStore(Configuration, Executor) - Method in class org.apache.flink.mesos.runtime.clusterframework.services.StandaloneMesosServices

createMesosWorkerStore(Configuration, Executor) - Method in class org.apache.flink.mesos.runtime.clusterframework.services.ZooKeeperMesosServices

createReconciliationCoordinator() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

createReconciliationCoordinator(SchedulerDriver) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

createResourceManager(Configuration, ResourceID, RpcService, HighAvailabilityServices, HeartbeatServices, MetricRegistry, FatalErrorHandler, ClusterInformation, String, JobManagerMetricGroup) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerFactory

createSelfActor() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

createTaskMonitor(SchedulerDriver) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

createTaskRouter() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

createTmParameters(Configuration, Logger) - Static method in class org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

credential() - Method in class org.apache.flink.mesos.util.MesosConfiguration

The credential to authenticate the framework principal.

D

data() - Method in class org.apache.flink.mesos.scheduler.messages.FrameworkMessage

disconnected(Disconnected) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Called when disconnected from Mesos.

Disconnected - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when the scheduler becomes "disconnected" from the master (e.g., the master fails and another is taking over).

Disconnected() - Constructor for class org.apache.flink.mesos.scheduler.messages.Disconnected

disconnected(SchedulerDriver) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

disk(double) - Static method in class org.apache.flink.mesos.Utils

Construct a disk resource.

disk(String, double) - Static method in class org.apache.flink.mesos.Utils

Construct a disk resource.

diskMB() - Method in class org.apache.flink.mesos.scheduler.Offer

dockerForcePullImage() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get Docker option to force pull image.

dockerParameters() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get Docker runtime parameters.

E

ENV_FLINK_CONTAINER_ID - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosConfigKeys

The Mesos task ID, used by the TM for informational purposes.

ENV_FLINK_TMP_DIR - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosConfigKeys

Reserved for future enhancement.

ENV_FRAMEWORK_NAME - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosConfigKeys

Standard environment variables used in DCOS environment.

ENV_JVM_ARGS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosConfigKeys

JVM arguments, used by the JM and TM.

ENV_TASK_NAME - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosConfigKeys

Standard environment variables used in DCOS environment.

equals(Object) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Error - Class in org.apache.flink.mesos.scheduler.messages

Message sent when there is an unrecoverable error in the scheduler or driver.

Error(String) - Constructor for class org.apache.flink.mesos.scheduler.messages.Error

error(SchedulerDriver, String) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.apache.flink.mesos.util.MesosArtifactServer.VirtualFileServerHandler

executorId() - Method in class org.apache.flink.mesos.scheduler.messages.ExecutorLost

executorId() - Method in class org.apache.flink.mesos.scheduler.messages.FrameworkMessage

executorLost(ExecutorLost) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

ExecutorLost - Class in org.apache.flink.mesos.scheduler.messages

Message sent when an executor has exited/terminated.

ExecutorLost(Protos.ExecutorID, Protos.SlaveID, int) - Constructor for class org.apache.flink.mesos.scheduler.messages.ExecutorLost

executorLost(SchedulerDriver, Protos.ExecutorID, Protos.SlaveID, int) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

F

FAILOVER_TIMEOUT_SECONDS - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

The failover timeout for the Mesos scheduler, after which running tasks are automatically shut down.

fatalError(String, Throwable) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

filters() - Method in class org.apache.flink.mesos.scheduler.messages.AcceptOffers

frameworkId() - Method in class org.apache.flink.mesos.scheduler.messages.Registered

frameworkInfo() - Method in class org.apache.flink.mesos.util.MesosConfiguration

The framework registration info.

frameworkMessage(FrameworkMessage) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

FrameworkMessage - Class in org.apache.flink.mesos.scheduler.messages

Message sent when an executor sends a message.

FrameworkMessage(Protos.ExecutorID, Protos.SlaveID, byte[]) - Constructor for class org.apache.flink.mesos.scheduler.messages.FrameworkMessage

frameworkMessage(SchedulerDriver, Protos.ExecutorID, Protos.SlaveID, byte[]) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

G

getArchivistClass() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

getArtifactServer() - Method in class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices

getArtifactServer() - Method in interface org.apache.flink.mesos.runtime.clusterframework.services.MesosServices

Gets the artifact server with which to serve essential resources to task managers.

getAttributeMap() - Method in class org.apache.flink.mesos.scheduler.Offer

getFrameworkID() - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Get the stored Mesos framework ID.

getFrameworkID() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

getFrameworkID() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

Get the persisted framework ID.

getId() - Method in class org.apache.flink.mesos.scheduler.Offer

getJobManagerClass() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

getLocalActorSystem() - Method in class org.apache.flink.mesos.runtime.clusterframework.services.AbstractMesosServices

getLocalActorSystem() - Method in interface org.apache.flink.mesos.runtime.clusterframework.services.MesosServices

Gets a local ActorSystem which is used for child actors within MesosResourceManager.

getNumWorkerRequestsPending() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

getNumWorkersPendingRegistration() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

getOffer() - Method in class org.apache.flink.mesos.scheduler.Offer

getOfferedTime() - Method in class org.apache.flink.mesos.scheduler.Offer

getRemaining() - Method in class org.apache.flink.mesos.util.MesosResourceAllocation

Gets the remaining resources.

getResourceID() - Method in class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode

getResourceManagerClass() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

getResources() - Method in class org.apache.flink.mesos.scheduler.Offer

getScalarValue(String) - Method in class org.apache.flink.mesos.scheduler.Offer

getScalarValues() - Method in class org.apache.flink.mesos.scheduler.Offer

getServerPort() - Method in class org.apache.flink.mesos.util.MesosArtifactServer

Get the server port on which the artifact server is listening.

getTaskManagerHostname() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the taskManager hostname.

getVMID() - Method in class org.apache.flink.mesos.scheduler.Offer

getWorker() - Method in class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode

gpus() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get the GPU units to use for the TaskManager Process.

gpus() - Method in class org.apache.flink.mesos.scheduler.Offer

gpus(double) - Static method in class org.apache.flink.mesos.Utils

Construct a gpu resource.

gpus(String, double) - Static method in class org.apache.flink.mesos.Utils

Construct a gpu resource.

H

handleMessage(Object) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

hashCode() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

hostname() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Get the worker's assigned hostname.

hostname() - Method in class org.apache.flink.mesos.scheduler.messages.AcceptOffers

hostname() - Method in class org.apache.flink.mesos.scheduler.Offer

I

INITIAL_TASKS - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

The initial number of Mesos tasks to allocate.

initialize() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

initialize() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

initializeServices(Configuration) - Method in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint

initializeServices(Configuration) - Method in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

internalDeregisterApplication(ApplicationStatus, String) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

L

launch(Protos.SlaveID, MesosResourceAllocation) - Method in class org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

Construct the TaskInfo needed to launch the worker.

launch(Protos.SlaveID, MesosResourceAllocation) - Method in interface org.apache.flink.mesos.scheduler.LaunchableTask

Prepare to launch the task by producing a Mesos TaskInfo record.

LaunchableMesosWorker - Class in org.apache.flink.mesos.runtime.clusterframework

Implements the launch of a Mesos worker.

LaunchableMesosWorker(MesosArtifactResolver, MesosTaskManagerParameters, ContainerSpecification, Protos.TaskID, MesosConfiguration) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

Construct a launchable Mesos worker.

LaunchableTask - Interface in org.apache.flink.mesos.scheduler

Specifies the task requirements and produces a Mesos TaskInfo description.

launchWorker(Protos.SlaveID, String) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Transition the worker to a launched state.

loadConfiguration(Configuration, Logger) - Static method in class org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

Loads the global configuration, adds the given dynamic properties configuration, and sets the temp directory paths.

LOG - Static variable in class org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

LOG - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

LOG - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

LOG - Static variable in class org.apache.flink.mesos.util.MesosResourceAllocation

logMesosConfig(Logger, MesosConfiguration) - Static method in class org.apache.flink.mesos.util.MesosConfiguration

A utility method to log relevant Mesos connection info.

M

main(String[]) - Static method in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint

main(String[]) - Static method in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

main(String[]) - Static method in class org.apache.flink.mesos.entrypoint.MesosTaskExecutorRunner

main(String[]) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

The entry point for the Mesos AppMaster.

MASTER_URL - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

The Mesos master URL.

masterInfo() - Method in class org.apache.flink.mesos.scheduler.messages.Registered

masterInfo() - Method in class org.apache.flink.mesos.scheduler.messages.ReRegistered

masterUrl() - Method in class org.apache.flink.mesos.util.MesosConfiguration

The Mesos connection string.

MAX_FAILED_TASKS - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

The maximum number of failed Mesos tasks before entirely stopping the Mesos session / job on Mesos.

mem(double) - Static method in class org.apache.flink.mesos.Utils

Construct a mem resource.

mem(String, double) - Static method in class org.apache.flink.mesos.Utils

Construct a mem resource.

memoryMB() - Method in class org.apache.flink.mesos.scheduler.Offer

MESOS_CONSTRAINTS_HARD_HOSTATTR - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_DOCKER - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Value for MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE setting.

MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE_MESOS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Value for MESOS_RESOURCEMANAGER_TASKS_CONTAINER_TYPE setting.

MESOS_RM_CONTAINER_DOCKER_FORCE_PULL_IMAGE - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_CONTAINER_DOCKER_PARAMETERS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_CONTAINER_IMAGE_NAME - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_CONTAINER_TYPE - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_CONTAINER_VOLUMES - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_TASKS_CPUS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_TASKS_GPUS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_TASKS_MEMORY_MB - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_RM_TASKS_SLOTS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_TM_BOOTSTRAP_CMD - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_TM_CMD - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_TM_HOSTNAME - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MESOS_TM_URIS - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MesosApplicationMasterRunner - Class in org.apache.flink.mesos.runtime.clusterframework

This class is the executable entry point for the Mesos Application Master.

MesosApplicationMasterRunner() - Constructor for class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

MesosArtifactResolver - Interface in org.apache.flink.mesos.util

An interface for resolving artifact URIs.

MesosArtifactServer - Class in org.apache.flink.mesos.util

A generic Mesos artifact server, designed specifically for use by the Mesos Fetcher.

MesosArtifactServer(String, String, int, Configuration) - Constructor for class org.apache.flink.mesos.util.MesosArtifactServer

MesosArtifactServer.UnknownFileHandler - Class in org.apache.flink.mesos.util

Handle a request for a non-existent file.

MesosArtifactServer.VirtualFileServerHandler - Class in org.apache.flink.mesos.util

Handle HEAD and GET requests for a specific file.

MesosConfigKeys - Class in org.apache.flink.mesos.runtime.clusterframework

The Mesos environment variables used for settings of the containers.

MesosConfiguration - Class in org.apache.flink.mesos.util

The typed configuration settings associated with a Mesos scheduler.

MesosConfiguration(String, Protos.FrameworkInfo.Builder, Option<Protos.Credential.Builder>) - Constructor for class org.apache.flink.mesos.util.MesosConfiguration

MesosEntrypointUtils - Class in org.apache.flink.mesos.entrypoint

Utils for Mesos entry points.

MesosEntrypointUtils() - Constructor for class org.apache.flink.mesos.entrypoint.MesosEntrypointUtils

MesosFlinkResourceManager - Class in org.apache.flink.mesos.runtime.clusterframework

Flink Resource Manager for Apache Mesos.

MesosFlinkResourceManager(Configuration, MesosConfiguration, MesosWorkerStore, LeaderRetrievalService, MesosTaskManagerParameters, ContainerSpecification, MesosArtifactResolver, int, int) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

MesosJobClusterEntrypoint - Class in org.apache.flink.mesos.entrypoint

Entry point for Mesos per-job clusters.

MesosJobClusterEntrypoint(Configuration, Configuration) - Constructor for class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint

MesosOptions - Class in org.apache.flink.mesos.configuration

The set of configuration options relating to mesos settings.

MesosOptions() - Constructor for class org.apache.flink.mesos.configuration.MesosOptions

MesosResourceAllocation - Class in org.apache.flink.mesos.util

An allocation of resources on a particular host from one or more Mesos offers, to be portioned out to tasks.

MesosResourceAllocation(Collection<Protos.Resource>) - Constructor for class org.apache.flink.mesos.util.MesosResourceAllocation

Creates an allocation of resources for tasks to take.

MesosResourceManager - Class in org.apache.flink.mesos.runtime.clusterframework

The Mesos implementation of the resource manager.

MesosResourceManager(RpcService, String, ResourceID, HighAvailabilityServices, HeartbeatServices, SlotManager, MetricRegistry, JobLeaderIdService, ClusterInformation, FatalErrorHandler, Configuration, MesosServices, MesosConfiguration, MesosTaskManagerParameters, ContainerSpecification, String, JobManagerMetricGroup) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

MesosResourceManagerActions - Interface in org.apache.flink.mesos.runtime.clusterframework

Actions defined by the MesosResourceManager.

MesosResourceManagerFactory - Class in org.apache.flink.mesos.runtime.clusterframework

ResourceManagerFactory which creates a MesosResourceManager.

MesosResourceManagerFactory(MesosServices, MesosConfiguration, MesosTaskManagerParameters, ContainerSpecification) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerFactory

MesosServices - Interface in org.apache.flink.mesos.runtime.clusterframework.services

Service factory interface for Mesos.

MesosServicesUtils - Class in org.apache.flink.mesos.runtime.clusterframework.services

Utilities for the MesosServices.

MesosServicesUtils() - Constructor for class org.apache.flink.mesos.runtime.clusterframework.services.MesosServicesUtils

MesosSessionClusterEntrypoint - Class in org.apache.flink.mesos.entrypoint

Entry point for Mesos session clusters.

MesosSessionClusterEntrypoint(Configuration, Configuration) - Constructor for class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

MesosTaskExecutorRunner - Class in org.apache.flink.mesos.entrypoint

The entry point for running a TaskManager in a Mesos container.

MesosTaskExecutorRunner() - Constructor for class org.apache.flink.mesos.entrypoint.MesosTaskExecutorRunner

MesosTaskManagerParameters - Class in org.apache.flink.mesos.runtime.clusterframework

This class describes the Mesos-specific parameters for launching a TaskManager process.

MesosTaskManagerParameters(double, int, MesosTaskManagerParameters.ContainerType, Option<String>, ContaineredTaskManagerParameters, List<Protos.Volume>, List<Protos.Parameter>, boolean, List<ConstraintEvaluator>, String, Option<String>, Option<String>, List<String>) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

MesosTaskManagerParameters.ContainerType - Enum in org.apache.flink.mesos.runtime.clusterframework

The supported containerizers.

MesosTaskManagerRunner - Class in org.apache.flink.mesos.runtime.clusterframework

The entry point for running a TaskManager in a Mesos container.

MesosTaskManagerRunner() - Constructor for class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerRunner

MesosWorkerStore - Interface in org.apache.flink.mesos.runtime.clusterframework.store

A store of Mesos workers and associated framework information.

MesosWorkerStore.Worker - Class in org.apache.flink.mesos.runtime.clusterframework.store

A stored worker.

MesosWorkerStore.WorkerState - Enum in org.apache.flink.mesos.runtime.clusterframework.store

The (planned) state of the worker.

message() - Method in class org.apache.flink.mesos.scheduler.messages.Error

N

network(double) - Static method in class org.apache.flink.mesos.Utils

Construct a network resource.

network(String, double) - Static method in class org.apache.flink.mesos.Utils

Construct a network resource.

networkMbps() - Method in class org.apache.flink.mesos.scheduler.Offer

newTaskID() - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Generate a new task ID for a worker.

newTaskID() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

newTaskID() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

Generates a new task ID.

newWorker(Protos.TaskID) - Static method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Create a new worker with the given taskID.

newWorker(Protos.TaskID, ResourceProfile) - Static method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Create a new worker with the given taskID.

O

Offer - Class in org.apache.flink.mesos.scheduler

An adapter class to transform a Mesos resource offer to a Fenzo VirtualMachineLease.

Offer(Protos.Offer) - Constructor for class org.apache.flink.mesos.scheduler.Offer

offerId() - Method in class org.apache.flink.mesos.scheduler.messages.OfferRescinded

offerIds() - Method in class org.apache.flink.mesos.scheduler.messages.AcceptOffers

offerRescinded(OfferRescinded) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Called when resource offers are rescinded.

OfferRescinded - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when an offer is no longer valid (e.g., the slave was lost or another framework used resources in the offer).

OfferRescinded(Protos.OfferID) - Constructor for class org.apache.flink.mesos.scheduler.messages.OfferRescinded

offerRescinded(SchedulerDriver, Protos.OfferID) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

offers() - Method in class org.apache.flink.mesos.scheduler.messages.ResourceOffers

operations() - Method in class org.apache.flink.mesos.scheduler.messages.AcceptOffers

org.apache.flink.mesos - package org.apache.flink.mesos

org.apache.flink.mesos.configuration - package org.apache.flink.mesos.configuration

org.apache.flink.mesos.entrypoint - package org.apache.flink.mesos.entrypoint

org.apache.flink.mesos.runtime.clusterframework - package org.apache.flink.mesos.runtime.clusterframework

org.apache.flink.mesos.runtime.clusterframework.services - package org.apache.flink.mesos.runtime.clusterframework.services

org.apache.flink.mesos.runtime.clusterframework.store - package org.apache.flink.mesos.runtime.clusterframework.store

org.apache.flink.mesos.scheduler - package org.apache.flink.mesos.scheduler

org.apache.flink.mesos.scheduler.messages - package org.apache.flink.mesos.scheduler.messages

org.apache.flink.mesos.util - package org.apache.flink.mesos.util

P

PORT_ASSIGNMENTS - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

Config parameter to configure which configuration keys will dynamically get a port assigned through Mesos.

portRanges() - Method in class org.apache.flink.mesos.scheduler.Offer

ports(Protos.Value.Range...) - Static method in class org.apache.flink.mesos.Utils

Construct a port resource.

ports(String, Protos.Value.Range...) - Static method in class org.apache.flink.mesos.Utils

Construct a port resource.

postStop() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

postStop() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

prepareLeadershipAsync() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

profile() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Get the resource profile associated with the worker.

putWorker(MesosWorkerStore.Worker) - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Put a worker into storage.

putWorker(MesosWorkerStore.Worker) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

putWorker(MesosWorkerStore.Worker) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

R

range(long, long) - Static method in class org.apache.flink.mesos.Utils

Construct a range value.

ranges(String, String, Protos.Value.Range...) - Static method in class org.apache.flink.mesos.Utils

Construct a range resource.

rangeValues(Collection<Protos.Resource>) - Static method in class org.apache.flink.mesos.Utils

Gets a stream of values from a collection of range resources.

rangeValues(Protos.Value.Range) - Static method in class org.apache.flink.mesos.Utils

Gets a stream of values from a range.

reacceptRegisteredWorkers(Collection<ResourceID>) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Accept the given registered workers into the internal state.

reconcile(ReconciliationCoordinator.Reconcile) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Handles a reconciliation request from a task monitor.

reconcile(ReconciliationCoordinator.Reconcile) - Method in interface org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerActions

Trigger reconciliation with the Mesos master.

recoverWorkers() - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Recover the stored workers.

recoverWorkers() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

recoverWorkers() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

registered(Registered) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Registered - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when the scheduler successfully registers with a Mesos master.

Registered(Protos.FrameworkID, Protos.MasterInfo) - Constructor for class org.apache.flink.mesos.scheduler.messages.Registered

registered(SchedulerDriver, Protos.FrameworkID, Protos.MasterInfo) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

RegisteredMesosWorkerNode - Class in org.apache.flink.mesos.runtime.clusterframework

A representation of a registered Mesos task managed by the MesosFlinkResourceManager.

RegisteredMesosWorkerNode(MesosWorkerStore.Worker) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode

releasePendingWorker(ResourceID) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Release the given pending worker.

releaseStartedWorker(RegisteredMesosWorkerNode) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Release the given started worker.

releaseWorker() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Transition the worker to a released state.

removePath(Path) - Method in class org.apache.flink.mesos.util.MesosArtifactServer

removeWorker(Protos.TaskID) - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Remove a worker from storage.

removeWorker(Protos.TaskID) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

removeWorker(Protos.TaskID) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

requestNewWorkers(int) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Plan for some additional workers to be launched.

reregistered(ReRegistered) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Called when reconnected to Mesos following a failover event.

ReRegistered - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when the scheduler re-registers with a newly elected Mesos master.

ReRegistered(Protos.MasterInfo) - Constructor for class org.apache.flink.mesos.scheduler.messages.ReRegistered

reregistered(SchedulerDriver, Protos.MasterInfo) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

resolve(Path) - Method in interface org.apache.flink.mesos.util.MesosArtifactResolver

resolve(Path) - Method in class org.apache.flink.mesos.util.MesosArtifactServer

RESOURCEMANAGER_FRAMEWORK_NAME - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

RESOURCEMANAGER_FRAMEWORK_PRINCIPAL - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

RESOURCEMANAGER_FRAMEWORK_ROLE - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

RESOURCEMANAGER_FRAMEWORK_SECRET - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

RESOURCEMANAGER_FRAMEWORK_USER - Static variable in class org.apache.flink.mesos.configuration.MesosOptions

resourceOffers(ResourceOffers) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Called when resource offers are made to the framework.

ResourceOffers - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when resources have been offered to this framework.

ResourceOffers(List<Protos.Offer>) - Constructor for class org.apache.flink.mesos.scheduler.messages.ResourceOffers

resourceOffers(SchedulerDriver, List<Protos.Offer>) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

resources(Protos.Resource...) - Static method in class org.apache.flink.mesos.Utils

Construct a list of resources.

roles() - Method in class org.apache.flink.mesos.util.MesosConfiguration

Gets the roles associated with the framework.

run(String[]) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

The instance entry point for the Mesos AppMaster.

runPrivileged(Configuration, Configuration) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosApplicationMasterRunner

The main work method, must run as a privileged action.

runTaskManager(String[], Class<? extends TaskManager>) - Static method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerRunner

S

scalar(String, String, double) - Static method in class org.apache.flink.mesos.Utils

Construct a scalar resource.

SchedulerProxy - Class in org.apache.flink.mesos.scheduler

This class reacts to callbacks from the Mesos scheduler driver.

SchedulerProxy(ActorRef) - Constructor for class org.apache.flink.mesos.scheduler.SchedulerProxy

setFrameworkID(Option<Protos.FrameworkID>) - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Set the stored Mesos framework ID.

setFrameworkID(Option<Protos.FrameworkID>) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

setFrameworkID(Option<Protos.FrameworkID>) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

Update the persisted framework ID.

shutdownApplication(ApplicationStatus, String) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Called to shut down the cluster (not a failover situation).

slaveID() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Get the worker's assigned slave ID.

slaveId() - Method in class org.apache.flink.mesos.scheduler.messages.ExecutorLost

slaveId() - Method in class org.apache.flink.mesos.scheduler.messages.FrameworkMessage

slaveId() - Method in class org.apache.flink.mesos.scheduler.messages.SlaveLost

slaveLost(SlaveLost) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

SlaveLost - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when a slave has been determined unreachable (e.g., machine failure, network partition).

SlaveLost(Protos.SlaveID) - Constructor for class org.apache.flink.mesos.scheduler.messages.SlaveLost

slaveLost(SchedulerDriver, Protos.SlaveID) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

StandaloneMesosServices - Class in org.apache.flink.mesos.runtime.clusterframework.services

MesosServices implementation for the standalone mode.

StandaloneMesosServices(ActorSystem, MesosArtifactServer) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.services.StandaloneMesosServices

StandaloneMesosWorkerStore - Class in org.apache.flink.mesos.runtime.clusterframework.store

A standalone Mesos worker store.

StandaloneMesosWorkerStore() - Constructor for class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

start() - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Start the worker store.

start() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

start() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

startNewWorker(ResourceProfile) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

state() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Get the worker's state.

status() - Method in class org.apache.flink.mesos.scheduler.messages.ExecutorLost

status() - Method in class org.apache.flink.mesos.scheduler.messages.StatusUpdate

statusUpdate(StatusUpdate) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Handles a task status update from Mesos.

StatusUpdate - Class in org.apache.flink.mesos.scheduler.messages

Message sent by the callback handler to the scheduler actor when the status of a task has changed (e.g., a slave is lost and so the task is lost, a task finishes and an executor sends a status update saying so, etc).

StatusUpdate(Protos.TaskStatus) - Constructor for class org.apache.flink.mesos.scheduler.messages.StatusUpdate

statusUpdate(SchedulerDriver, Protos.TaskStatus) - Method in class org.apache.flink.mesos.scheduler.SchedulerProxy

stop(boolean) - Method in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

Stop the worker store.

stop(boolean) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.StandaloneMesosWorkerStore

stop(boolean) - Method in class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

stop() - Method in class org.apache.flink.mesos.util.MesosArtifactServer

Stops the artifact server.

stopClusterServices(boolean) - Method in class org.apache.flink.mesos.entrypoint.MesosJobClusterEntrypoint

stopClusterServices(boolean) - Method in class org.apache.flink.mesos.entrypoint.MesosSessionClusterEntrypoint

stopWorker(RegisteredMesosWorkerNode) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

T

takeRanges(String, int, Set<String>) - Method in class org.apache.flink.mesos.util.MesosResourceAllocation

Takes some amount of range resources (e.g.

takeScalar(String, double, Set<String>) - Method in class org.apache.flink.mesos.util.MesosResourceAllocation

Takes some amount of scalar resources (e.g.

TASK_ID_PATTERN - Static variable in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Pattern replaced in the MesosTaskManagerParameters.MESOS_TM_HOSTNAME by the actual task id of the Mesos task.

taskID() - Method in class org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

taskID() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

Get the worker's task ID.

TASKID_FORMAT - Static variable in interface org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore

The template for naming the worker.

taskRequest() - Method in class org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

taskRequest() - Method in interface org.apache.flink.mesos.scheduler.LaunchableTask

Get a representation of the task requirements as understood by Fenzo.

TaskSchedulerBuilder - Interface in org.apache.flink.mesos.scheduler

A builder for the Fenzo task scheduler.

taskTerminated(TaskMonitor.TaskTerminated) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Handles a termination notification from a task monitor.

taskTerminated(TaskMonitor.TaskTerminated) - Method in interface org.apache.flink.mesos.runtime.clusterframework.MesosResourceManagerActions

Notify that the given Mesos task has been terminated.

toString() - Method in class org.apache.flink.mesos.runtime.clusterframework.LaunchableMesosWorker

toString() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

toString() - Method in class org.apache.flink.mesos.runtime.clusterframework.RegisteredMesosWorkerNode

toString() - Method in class org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.Worker

toString() - Method in class org.apache.flink.mesos.scheduler.messages.AcceptOffers

toString() - Method in class org.apache.flink.mesos.scheduler.messages.Disconnected

toString() - Method in class org.apache.flink.mesos.scheduler.messages.Error

toString() - Method in class org.apache.flink.mesos.scheduler.messages.ExecutorLost

toString() - Method in class org.apache.flink.mesos.scheduler.messages.FrameworkMessage

toString() - Method in class org.apache.flink.mesos.scheduler.messages.OfferRescinded

toString() - Method in class org.apache.flink.mesos.scheduler.messages.Registered

toString() - Method in class org.apache.flink.mesos.scheduler.messages.ReRegistered

toString() - Method in class org.apache.flink.mesos.scheduler.messages.ResourceOffers

toString() - Method in class org.apache.flink.mesos.scheduler.messages.SlaveLost

toString() - Method in class org.apache.flink.mesos.scheduler.messages.StatusUpdate

toString() - Method in class org.apache.flink.mesos.scheduler.Offer

toString() - Method in class org.apache.flink.mesos.util.MesosConfiguration

toString() - Method in class org.apache.flink.mesos.util.MesosResourceAllocation

toString(Collection<Protos.Resource>) - Static method in class org.apache.flink.mesos.Utils

Gets a string representation of a collection of resources.

toString(Protos.Resource) - Static method in class org.apache.flink.mesos.Utils

Gets a string representation of a resource.

toString(Protos.Value.Ranges) - Static method in class org.apache.flink.mesos.Utils

Gets a string representation of a collection of ranges.

toString(Protos.Value.Range) - Static method in class org.apache.flink.mesos.Utils

Gets a string representation of a range.

U

UnknownFileHandler() - Constructor for class org.apache.flink.mesos.util.MesosArtifactServer.UnknownFileHandler

UNRESERVED_ROLE - Static variable in class org.apache.flink.mesos.Utils

The special 'unreserved' role.

uri(URL, boolean) - Static method in class org.apache.flink.mesos.Utils

Construct a Mesos URI.

uri(MesosArtifactResolver, ContainerSpecification.Artifact) - Static method in class org.apache.flink.mesos.Utils

Construct a Mesos URI.

uris() - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters

Get custom artifact URIs.

Utils - Class in org.apache.flink.mesos

Collection of utility methods.

Utils() - Constructor for class org.apache.flink.mesos.Utils

V

valueOf(String) - Static method in enum org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters.ContainerType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.WorkerState

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.mesos.runtime.clusterframework.MesosTaskManagerParameters.ContainerType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.mesos.runtime.clusterframework.store.MesosWorkerStore.WorkerState

Returns an array containing the constants of this enum type, in the order they are declared.

variable(String, String) - Static method in class org.apache.flink.mesos.Utils

Construct a Mesos environment variable.

VirtualFileServerHandler(Path) - Constructor for class org.apache.flink.mesos.util.MesosArtifactServer.VirtualFileServerHandler

W

withFrameworkInfo(Protos.FrameworkInfo.Builder) - Method in class org.apache.flink.mesos.util.MesosConfiguration

Revise the configuration with updated framework info.

withLeaseRejectAction(Action1<VirtualMachineLease>) - Method in interface org.apache.flink.mesos.scheduler.TaskSchedulerBuilder

Set the callback action for rejecting a lease.

workerStarted(ResourceID) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager

Accept the given started worker into the internal state.

workerStarted(ResourceID) - Method in class org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager

Callback when a worker was started.

Z

ZooKeeperMesosServices - Class in org.apache.flink.mesos.runtime.clusterframework.services

MesosServices implementation for the ZooKeeper high availability based mode.

ZooKeeperMesosServices(ActorSystem, MesosArtifactServer, ZooKeeperUtilityFactory) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.services.ZooKeeperMesosServices

ZooKeeperMesosWorkerStore - Class in org.apache.flink.mesos.runtime.clusterframework.store

A ZooKeeper-backed Mesos worker store.

ZooKeeperMesosWorkerStore(ZooKeeperStateHandleStore<MesosWorkerStore.Worker>, ZooKeeperSharedValue, ZooKeeperSharedCount) - Constructor for class org.apache.flink.mesos.runtime.clusterframework.store.ZooKeeperMesosWorkerStore

A B C D E F G H I L M N O P R S T U V W Z