Package | Description |
---|---|
org.apache.flink.mesos.runtime.clusterframework | |
org.apache.flink.runtime.clusterframework |
This package contains the cluster resource management functionality.
|
org.apache.flink.runtime.clusterframework.types | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.yarn |
Modifier and Type | Class and Description |
---|---|
class |
RegisteredMesosWorkerNode
A representation of a registered Mesos task managed by the
MesosFlinkResourceManager . |
Modifier and Type | Class and Description |
---|---|
class |
FlinkResourceManager<WorkerType extends ResourceIDRetrievable>
Worker allocation steps
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceID
Class for Resource Ids assigned at the FlinkResourceManager.
|
Modifier and Type | Method and Description |
---|---|
akka.actor.Props |
LocalFlinkMiniCluster.getResourceManagerProps(Class<? extends FlinkResourceManager<? extends ResourceIDRetrievable>> resourceManagerClass,
Configuration configuration,
LeaderRetrievalService leaderRetrievalService) |
Modifier and Type | Class and Description |
---|---|
class |
RegisteredYarnWorkerNode
A representation of a registered Yarn container managed by the
YarnFlinkResourceManager . |
class |
YarnContainerInLaunch
This class describes a container in which a TaskManager is being launched (or
has been launched) but where the TaskManager has not properly registered, yet.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.