All Classes

Class	Description
AbstractFlinkDeploymentObserver	Base observer for session and application clusters.
AbstractFlinkResource<SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>	Abstract base class Flink resources.
AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,?>>	Base observer for all Flink resources.
AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>	Base class for all Flink resource reconcilers.
AbstractFlinkService	An abstract FlinkService containing some common implementations for the native and standalone Flink Services.
AbstractFlinkSpec	The common spec.
AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>>	Reconciler responsible for handling the job lifecycle according to the desired and current states.
AdmissionHandler	Rest endpoint for validation requests.
ApplicationObserver	The observer of Mode.APPLICATION cluster.
ApplicationReconciler	Reconciler Flink Application deployments.
ArtifactFetcher	The artifact fetcher.
ArtifactManager	Manage the user artifacts.
AuditUtils	Responsible for logging resource event/status updates.
AutoScalerInfo	Class for encapsulating information stored for each resource when using the autoscaler.
AutoscalerLoader	Loads the active Autoscaler implementation from the classpath.
AutoScalerOptions	Config options related to the autoscaler module.
AutoScalerUtils	AutoScaler utilities.
AutoscalingExample	Autoscaling Example.
CheckpointHistoryWrapper	Custom Response for handling checkpoint history in a multi-version compatible way.
ClusterHealthEvaluator	Evaluates whether the cluster is healthy.
ClusterHealthInfo	Represents information about job health.
ClusterHealthObserver	An observer to observe the cluster health.
CmdStandaloneJobManagerDecorator	Attach the command and args to the main container for running the JobManager in standalone mode.
CmdStandaloneTaskManagerDecorator	Attach the command and args to the main container for running the TaskManager in standalone mode.
CollectedMetrics	Topology and collected metric history.
CommonStatus<SPEC extends AbstractFlinkSpec>	Last observed common status of the Flink deployment/Flink SessionJob.
ConfigOptionsDocGenerator	Class used for generating code based documentation of configuration parameters.
ConfigOptionUtils	ConfigOption utilities.
CrdCompatibilityChecker	Utility for checking backward CRD compatibility.
CrdCompatibilityChecker.CompatibilityError	Compatibility Error class.
CrdConstants	Constants used by the CRD.
CrdReferenceDoclet	Doclet for generating the FlinkDeployment CRD reference.
CustomCheckpointingStatisticsHeaders	Custom Headers for handling checkpoint history in a multi-version compatible way.
CustomDashboardConfiguration	Custom Response for handling dashboard configs.
CustomDashboardConfigurationHeaders	Message headers for the CustomDashboardConfiguration.
CustomResourceMetrics<CR extends io.fabric8.kubernetes.client.CustomResource<?,?>>	Custom resource metric type.
DefaultRequestMutator<T extends io.fabric8.kubernetes.api.model.KubernetesResource>	The default request mutator.
DefaultValidator	Default validator implementation for FlinkDeployment.
DeploymentFailedException	Exception to signal terminal deployment failure.
Diff<T>	Contains the differences between two Diffable class fields.
Diffable<T>	Diffable classes can be compared with other Diffable objects for differences.
DiffBuilder<T>	Assists in implementing comparison of Diffable instances.
DiffResult<T>	Contains a collection of the differences between two Diffable objects.
DiffType	Spec change type.
EnvUtils	Util to get value from environments.
EvaluatedScalingMetric	Evaluated scaling metric.
EventRecorder	Helper class for creating Kubernetes events for Flink resources.
EventRecorder.Component	The component of events.
EventRecorder.Reason	The reason codes of events.
EventRecorder.Type	The type of the events.
EventSourceUtils	Utility class to locate secondary resources.
EventUtils	The util to generate an event for the target resource.
Fabric8FlinkStandaloneKubeClient	The Implementation of FlinkStandaloneKubeClient.
FileSystemBasedArtifactFetcher	Leverage the flink filesystem plugin to fetch the artifact.
FileSystemWatchService	Service which is able to watch local filesystem directories.
FlinkConfigBuilder	Builder to get effective flink config from FlinkDeployment.
FlinkConfigManager	Configuration manager for the Flink operator.
FlinkDeployment	Custom resource definition that represents both Application and Session deployments.
FlinkDeploymentContext	Context for reconciling a Flink resource.
FlinkDeploymentController	Controller that runs the main reconcile loop for Flink deployments.
FlinkDeploymentList	Multiple Flink deployments.
FlinkDeploymentMetrics	FlinkDeployment metrics.
FlinkDeploymentObserverFactory	The factory to create the observer based on the FlinkDeployment mode.
FlinkDeploymentReconciliationStatus	Status of the last reconcile step for the flink deployment.
FlinkDeploymentSpec	Spec that describes a Flink application or session cluster deployment.
FlinkDeploymentStatus	Last observed status of the Flink deployment.
FlinkMetric	Enum representing the collected Flink metrics for autoscaling.
FlinkMutator	The default mutator.
FlinkOperator	Main Class for Flink native k8s operator.
FlinkOperatorConfiguration	Configuration class for operator.
FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration	Enables configurable retry mechanism for reconciliation errors.
FlinkOperatorWebhook	Main Class for Flink native k8s operator.
FlinkResourceContext<CR extends AbstractFlinkResource<?,?>>	Context for reconciling a Flink resource.
FlinkResourceContextFactory	Factory for creating the FlinkResourceContext.
FlinkResourceException	Exception to display as JSON in CRD.
FlinkResourceExceptionUtils	Flink Resource Exception utilities.
FlinkResourceListener	Listener interface for Flink resource related events and status changes.
FlinkResourceListener.ResourceContext<R extends AbstractFlinkResource<?,?>>	Base for Resource Event and StatusUpdate contexts.
FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,?>>	Context for Resource Event listener methods.
FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>>	Context for Status listener methods.
FlinkResourceValidator	Validator for different resources.
FlinkService	Service for submitting and interacting with Flink clusters and jobs.
FlinkSessionJob	Custom resource definition that represents a flink session job.
FlinkSessionJobContext	Context for reconciling a Flink resource.
FlinkSessionJobController	Controller that runs the main reconcile loop for FlinkSessionJob.
FlinkSessionJobList	Multiple Flink session jobs.
FlinkSessionJobMetrics	FlinkSessionJob metrics.
FlinkSessionJobObserver	The observer of FlinkSessionJob.
FlinkSessionJobReconciliationStatus	Status of the last reconcile step for the flink sessionjob.
FlinkSessionJobSpec	Spec that describes a Flink session job.
FlinkSessionJobStatus	Last observed status of the Flink Session job.
FlinkStandaloneKubeClient	Extension of the FlinkKubeClient that is used for Flink standalone deployments.
FlinkUtils	Flink Utility methods used by the operator.
FlinkValidator	Validator for FlinkDeployment creation and updates.
FlinkVersion	Enumeration for supported Flink versions.
HealthProbe	Flink operator health probe.
HttpArtifactFetcher	Download the jar from the http resource.
HttpBootstrap	Class for serving HTTP requests for the health probe.
InformerManager	The manager of the informers.
IngressSpec	Ingress spec.
IngressUtils	Ingress utilities.
InitStandaloneTaskManagerDecorator	An initializer for the TaskManager FlinkPod in standalone mode.
IOMetricsInfo	IO metrics information.
JobAutoScaler	Per-job Autoscaler instance.
JobAutoScalerFactory	Factory to construct a new autoscaler instance.
JobAutoscalerFactoryImpl	Factory for loading JobAutoScalerImpl included in this module.
JobAutoScalerImpl	Application and SessionJob autoscaler.
JobManagerDeploymentStatus	Status of the Flink JobManager Kubernetes deployment.
JobManagerSpec	JobManager spec.
JobSpec	Flink job spec.
JobState	Enum describing the desired job state.
JobStatus	Last observed status of the Flink job within an application deployment.
JobStatusObserver<R extends AbstractFlinkResource<?,?>>	An observer to observe the job status.
JobTopology	Structure representing information about the jobgraph that is relevant for scaling.
JobVertexScaler	Component responsible for computing vertex parallelism based on the scaling metrics.
JobVertexSerDeModule	Jackson serializer module for JobVertexID.
KubernetesClientMetrics	Kubernetes client metrics.
KubernetesClientUtils	Kubernetes client utils.
KubernetesDeploymentMode	Enum to control Flink deployment mode on Kubernetes.
KubernetesOperatorConfigOptions	This class holds configuration constants used by flink operator.
KubernetesOperatorMetricGroup	Base metric group for Flink Operator System metrics.
KubernetesOperatorMetricOptions	Configuration options for metrics.
KubernetesOperatorScopeFormat	Format for metrics.
KubernetesResourceMetricGroup	Base metric group for Flink Operator Resource level metrics.
KubernetesResourceNamespaceMetricGroup	Base metric group for Flink Operator Resource namespace level metrics.
KubernetesResourceNamespaceScopeFormat	Format for metrics.
KubernetesResourceScopeFormat	Format for metrics.
KubernetesStandaloneClusterDescriptor	Standalone Kubernetes specific ClusterDescriptor implementation.
LifecycleMetrics<CR extends AbstractFlinkResource<?,?>>	Utility for tracking resource lifecycle metrics globally and per namespace.
LifecycleMetrics.Transition	Pojo for encapsulating state transitions and whether we should measure time from the beginning of from or since the last update.
ListenerUtils	Flink resource listener utilities.
MetricAggregator	Enum specifying which aggregator to use when getting a metric value.
MetricManager<CR extends AbstractFlinkResource<?,?>>	Metric manager for Operator managed custom resources.
MissingJobManagerException	Exception to signal missing job manager.
MissingSessionJobException	Exception to signal missing session job.
Mode	The mode of FlinkDeployment.
NativeFlinkService	Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.
NoopJobAutoscalerFactory	An autoscaler implementation which does nothing.
Observer<CR extends AbstractFlinkResource<?,?>>	The Observer of custom resource.
OperatorHealthHandler	Simple code which returns HTTP 200 messages if the service is live, and HTTP 500 messages if the service is down.
OperatorHealthService	Health probe service.
OperatorJosdkMetrics	Implementation of Metrics to monitor and forward JOSDK metrics to MetricRegistry.
OperatorMetricUtils	Utility class for flink based operator metrics.
OperatorMetricUtils.SynchronizedCounter	Thread safe Counter wrapper.
OperatorMetricUtils.SynchronizedHistogram	Thread safe Histogram wrapper.
OperatorMetricUtils.SynchronizedMeterView	Thread safe MeterView wrapper.
Reconciler<CR extends AbstractFlinkResource<?,?>>	The interface of reconciler.
ReconcilerFactory	The factory to create reconciler based on app mode.
ReconciliationException	Exception for wrapping reconciliation errors.
ReconciliationMetadata	Extra metadata to be attached to the reconciled spec.
ReconciliationState	Current state of the reconciliation.
ReconciliationStatus<SPEC extends AbstractFlinkSpec>	Status of the last reconcile step for the FlinkDeployment/FlinkSessionJob.
ReconciliationUtils	Reconciliation utilities.
RecoveryFailureException	Exception to signal non-terminal deployment failure.
ReflectiveDiffBuilder<T>	Assists in comparing Diffable objects with reflection.
ReloadableSslContext	SSL context which is able to reload keystore.
Resource	Resource spec.
ResourceLifecycleMetricTracker	Lifecycle state transition tracker for a single resource.
ResourceLifecycleState	Enum encapsulating the lifecycle state of a Flink resource.
RestApiMetricsCollector	Metric collector using flink rest api.
Savepoint	Represents information about a finished savepoint.
SavepointFetchResult	Result of a fetch savepoint operation.
SavepointFormatType	Savepoint format type.
SavepointInfo	Stores savepoint related information.
SavepointObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>	An observer of savepoint progress.
SavepointStatus	Enum encapsulating the lifecycle state of a Flink resource.
SavepointTriggerRequestBody	RequestBody to trigger savepoints.
SavepointTriggerType	Savepoint trigger mechanism.
SavepointUtils	Savepoint utilities.
ScalingExecutor	Class responsible for executing scaling decisions.
ScalingMetric	Supported scaling metrics.
ScalingMetricCollector	Metric collector using flink rest api.
ScalingMetricEvaluator	Job scaling evaluator for autoscaler.
ScalingMetrics	Utilities for computing scaling metrics based on Flink metrics.
ScalingSummary	Scaling summary returned by the ScalingMetricEvaluator.
SessionJobReconciler	The reconciler for the FlinkSessionJob.
SessionObserver	The observer of the Mode.SESSION cluster.
SessionReconciler	Reconciler responsible for handling the session cluster lifecycle according to the desired and current states.
SpecDiff	Spec diff annotation.
SpecDiff.Config	Spec diff config annotation.
SpecDiff.Entry	Spec diff config annotation entry.
SpecUtils	Spec utilities.
SpecWithMeta<T extends AbstractFlinkSpec>	Utility class for encapsulating Kubernetes resource spec and meta fields during serialization.
StandaloneFlinkService	Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.
StandaloneKubernetesConfigOptionsInternal	This class holds internal configuration constants used by flink operator when deploying flink clusters in standalone mode.
StandaloneKubernetesConfigOptionsInternal.ClusterMode	The different modes that a Flink cluster can be deployed in.
StandaloneKubernetesJobManagerFactory	Utility class for constructing all the Kubernetes for the JobManager deploying in standalone mode.
StandaloneKubernetesJobManagerParameters	A Utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the JobManager deployment used for standalone cluster deployments.
StandaloneKubernetesTaskManagerFactory	Utility class for constructing the TaskManager Deployment when deploying in standalone mode.
StandaloneKubernetesTaskManagerParameters	A utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the TaskManager deployment used for standalone deployments.
StandaloneKubernetesUtils	Standalone Kubernetes Utils.
StatusConflictException	Exception for status updates.
StatusRecorder<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>	Helper class for status management and updates.
StopWithSavepointRequestBody	RequestBody for stopping a job with a savepoint.
TaskManagerInfo	Last observed status of the Flink job within an application deployment.
TaskManagerSpec	TaskManager spec.
UnknownJobException	Exception to signal unrecognized job found.
UpgradeMode	Enum to control Flink job upgrade behavior.
UserLibMountDecorator	Mount the Flink User Lib directory to enable Flink to pick up a Jars defined in pipeline.classpaths.
Utils	Contains various shared utility functions.
ValidationException	Exception to signal validation failure.
ValidatorUtils	Validator utilities.
VertexInfo	Job vertex information.