Modifier and Type | Class and Description |
---|---|
class |
KubernetesWorkerNode
A stored Kubernetes worker, which contains the kubernetes pod.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceID
Class for Resource Ids identifying Flink's distributed components.
|
class |
SlotID
Unique identifier for a slot on a TaskManager.
|
Modifier and Type | Class and Description |
---|---|
class |
ResourceManager<WorkerType extends ResourceIDRetrievable>
ResourceManager implementation.
|
class |
ResourceManagerFactory<T extends ResourceIDRetrievable>
ResourceManager factory. |
Modifier and Type | Class and Description |
---|---|
class |
AbstractResourceManagerDriver<WorkerType extends ResourceIDRetrievable>
Abstract common base class for implementations of
ResourceManagerDriver . |
class |
ActiveResourceManager<WorkerType extends ResourceIDRetrievable>
An active implementation of
ResourceManager . |
class |
ActiveResourceManagerFactory<WorkerType extends ResourceIDRetrievable>
Factory class for creating
ActiveResourceManager with various implementations of ResourceManagerDriver . |
interface |
ResourceEventHandler<WorkerType extends ResourceIDRetrievable>
Callback interfaces for handling resource events from external resource managers.
|
interface |
ResourceManagerDriver<WorkerType extends ResourceIDRetrievable>
A
ResourceManagerDriver is responsible for requesting and releasing resources from/to a
particular external resource manager. |
Modifier and Type | Class and Description |
---|---|
class |
WorkerRegistration<WorkerType extends ResourceIDRetrievable>
This class extends the
TaskExecutorConnection , adding the worker information. |
Modifier and Type | Class and Description |
---|---|
class |
YarnWorkerNode
A stored YARN worker, which contains the YARN container.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.