All Classes

Class	Description
AbstractKubernetesParameters	Abstract class for the KubernetesParameters.
AbstractKubernetesStepDecorator	An abstract KubernetesStepDecorator contains common implementations for different plug-in features.
AbstractKubernetesWatcher<T extends io.fabric8.kubernetes.api.model.HasMetadata,K extends KubernetesResource<T>>	Watcher for resources in Kubernetes.
ClusterIPService	The service type of ClusterIP.
CmdJobManagerDecorator	Attach the command and args to the main container for running the JobManager.
CmdTaskManagerDecorator	Attach the command and args to the main container for running the TaskManager.
Constants	Constants for kubernetes.
DefaultKubernetesArtifactUploader	Default KubernetesArtifactUploader implementation.
Endpoint	Represent an endpoint.
EnvSecretsDecorator	Support setting environment variables via Secrets.
ExternalServiceDecorator	Creates an external Service to expose the rest port of the Flink JobManager(s).
Fabric8FlinkKubeClient	The implementation of FlinkKubeClient.
FlinkConfMountDecorator	Mounts the log4j.properties, logback.xml, and config.yaml configuration on the JobManager or TaskManager pod.
FlinkKubeClient	The client to talk with kubernetes.
FlinkKubeClient.WatchCallbackHandler<T>	Callback handler for kubernetes resources.
FlinkKubeClientFactory	A FlinkKubeClientFactory for creating the FlinkKubeClient.
FlinkPod	A collection of variables that composes a JobManager/TaskManager Pod.
FlinkPod.Builder	Builder for creating a FlinkPod.
HadoopConfMountDecorator	Mount the custom Hadoop Configuration to the JobManager(s)/TaskManagers.
HeadlessClusterIPService	The service type of Headless ClusterIP, which is an variant of ClusterIP.
InitJobManagerDecorator	An initializer for the JobManager FlinkPod.
InitTaskManagerDecorator	An initializer for the TaskManager FlinkPod.
InternalServiceDecorator	Creates an internal Service which forwards the requests from the TaskManager(s) to the active JobManager.
KerberosMountDecorator	Mount the custom Kerberos Configuration and Credential to the JobManager(s)/TaskManagers.
KubernetesApplicationClusterEntrypoint	An ApplicationClusterEntryPoint for Kubernetes.
KubernetesArtifactUploader	Local artifact uploader for Kubernetes programs.
KubernetesCheckpointIDCounter	CheckpointIDCounter implementation for Kubernetes.
KubernetesCheckpointRecoveryFactory	Factory to create CompletedCheckpointStore and CheckpointIDCounter.
KubernetesCheckpointStoreUtil	Singleton CheckpointStoreUtil implementation for Kubernetes.
KubernetesClusterClientFactory	A ClusterClientFactory for a Kubernetes cluster.
KubernetesClusterDescriptor	Kubernetes specific ClusterDescriptor implementation.
KubernetesConfigMap	Represent ConfigMap resource in kubernetes.
KubernetesConfigMapSharedInformer	The shared informer for ConfigMap, it can be used as a shared watcher.
KubernetesConfigMapSharedWatcher	The shared watcher interface for ConfigMap.
KubernetesConfigOptions	This class holds configuration constants used by Flink's kubernetes runners.
KubernetesConfigOptions.ImagePullPolicy	The container image pull policy.
KubernetesConfigOptions.NodePortAddressType	The flink rest service exposed type.
KubernetesConfigOptions.ServiceExposedType	The flink rest service exposed type.
KubernetesConfigOptionsInternal	Kubernetes configuration options that are not meant to be set by the user.
KubernetesDeploymentTarget	A class containing all the supported deployment target names for Kubernetes.
KubernetesException	Kubernetes related checked exceptions.
KubernetesExecutionPlanStoreUtil	Singleton ExecutionPlanStoreUtil implementation for Kubernetes.
KubernetesHaServicesFactory	Factory for creating Kubernetes high availability services.
KubernetesHighAvailabilityOptions	The set of configuration options relating to Kubernetes high-availability settings.
KubernetesJobManagerFactory	Utility class for constructing all the Kubernetes components on the client-side.
KubernetesJobManagerParameters	A utility class helps parse, verify, and manage the Kubernetes side parameters that are used for constructing the JobManager Pod and all accompanying resources connected to it.
KubernetesJobManagerSpecification	Composition of the created Kubernetes components that represents a Flink application.
KubernetesLeaderElectionConfiguration	Configuration specific to KubernetesLeaderElector.
KubernetesLeaderElectionDriver	LeaderElectionDriver for Kubernetes.
KubernetesLeaderElectionDriverFactory	Factory that instantiates a KubernetesLeaderElectionDriver.
KubernetesLeaderElectionHaServices	Kubernetes HA services that use a single leader election service per JobManager.
KubernetesLeaderElector	Represent KubernetesLeaderElector in kubernetes.
KubernetesLeaderElector.LeaderCallbackHandler	Callback handler for leader election.
KubernetesLeaderRetrievalDriver	The counterpart to the KubernetesLeaderElectionDriver.
KubernetesLeaderRetrievalDriverFactory	Factory that instantiates a KubernetesLeaderRetrievalDriver in single leader election mode.
KubernetesOwnerReference	Represent Owner reference resource in kubernetes.
KubernetesParameters	A common collection of parameters that is used to construct the JobManager/TaskManager Pods, including the accompanying Kubernetes resources that together represent a Flink application.
KubernetesPod	Represent KubernetesPod resource in kubernetes.
KubernetesPodsWatcher	Watcher for pods in Kubernetes.
KubernetesResource<T>	Represent a kubernetes resource.
KubernetesResourceManagerDriver	Implementation of ResourceManagerDriver for Kubernetes deployment.
KubernetesResourceManagerDriverConfiguration	Configuration specific to KubernetesResourceManagerDriver.
KubernetesResourceManagerFactory	ActiveResourceManagerFactory implementation which creates ActiveResourceManager with KubernetesResourceManagerDriver.
KubernetesSecretEnvVar	Represents EnvVar resource in Kubernetes.
KubernetesService	Represent Service resource in kubernetes.
KubernetesSessionCli	Kubernetes customized commandline.
KubernetesSessionClusterEntrypoint	Entry point for a Kubernetes session cluster.
KubernetesSessionClusterExecutor	The PipelineExecutor to be used when executing a job on an already running cluster.
KubernetesSessionClusterExecutorFactory	An PipelineExecutorFactory for executing jobs on an existing (session) cluster.
KubernetesSharedInformer<T extends io.fabric8.kubernetes.api.model.HasMetadata,R>	Base class for shared watcher based on SharedIndexInformer.
KubernetesSharedWatcher<T>	The interface for the Kubernetes shared watcher.
KubernetesSharedWatcher.Watch	The Watch returned after creating watching, which can be used to close the watching.
KubernetesStateHandleStore<T extends Serializable>	Class which stores state via the provided RetrievableStateStorageHelper and writes the returned state handle to ConfigMap.
KubernetesStepDecorator	A set of functions that together represent a feature in pods that are deployed for the JobManager(s) or the TaskManager(s), which provides an extension to the way the given Flink application works.
KubernetesTaskExecutorRunner	This class is the executable entry point for running a TaskExecutor in a Kubernetes pod.
KubernetesTaskManagerFactory	Utility class for constructing the TaskManager Pod on the JobManager.
KubernetesTaskManagerParameters	A utility class helps parse, verify, and manage the Kubernetes side parameters that are used for constructing the TaskManager Pod.
KubernetesToleration	Represent Toleration resource in kubernetes.
KubernetesTooOldResourceVersionException	Kubernetes too old resource version exception.
KubernetesUtils	Common utils for Kubernetes.
KubernetesWatch	Watch resource in Kubernetes.
KubernetesWorkerNode	A stored Kubernetes worker, which contains the kubernetes pod.
KubernetesWorkerResourceSpecFactory	Implementation of WorkerResourceSpecFactory for Kubernetes deployments.
LoadBalancerService	The service type of LoadBalancer.
MountSecretsDecorator	Support mounting Secrets on the JobManager or TaskManager pod..
NodePortService	The service type of NodePort.
PodTemplateMountDecorator	Ship and mount Constants.TASK_MANAGER_POD_TEMPLATE_FILE_NAME on the JobManager.
ServiceType	An abstract class represents the service type that flink supported.