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.
AbstractJobReconciler.AvailableUpgradeMode	Object to capture available upgrade mode.
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.
AutoScalerEvent	The Jdbc autoscaler event.
AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>	Handler for autoscaler events.
AutoScalerEventHandler.Type	The type of the events.
AutoscalerEventHandlerFactory	The factory of AutoScalerEventHandler.
AutoscalerEventHandlerFactory.EventHandlerType	Out-of-box event handler type.
AutoscalerEventUtils	The utils of AutoScalerEventHandler.
AutoscalerFactory	The factory of JobAutoScaler.
AutoscalerFlinkMetrics	Autoscaler metrics for observability.
AutoScalerOptions	Config options related to the autoscaler module.
AutoScalerSerDeModule	Jackson serializer module for JobVertexID.
AutoscalerStandaloneOptions	Config options related to the autoscaler standalone module.
AutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>>	The state store is responsible for storing all state during scaling.
AutoscalerStateStoreFactory	The factory of AutoScalerStateStore.
AutoscalerStateStoreFactory.StateStoreType	Out-of-box state store type.
AutoScalerUtils	AutoScaler utilities.
AutoscalingExample	Autoscaling Example.
CalendarUtils	Calendar utilities.
CanaryResourceManager<CR extends AbstractFlinkResource<?,?>>	Logic encapsulating canary tests.
Checkpoint	Represents information about a finished checkpoint.
CheckpointFetchResult	Result of a fetch checkpoint operation.
CheckpointHistoryWrapper	Custom Response for handling checkpoint history in a multi-version compatible way.
CheckpointHistoryWrapper.CompletedCheckpointInfo	Information about the latest completed checkpoint/savepoint.
CheckpointHistoryWrapper.PendingCheckpointInfo	Information about the currently pending checkpoint/savepoint.
CheckpointInfo	Stores checkpoint-related information.
CheckpointType	Checkpoint format type.
ClusterHealthEvaluator	Evaluates whether the cluster is healthy.
ClusterHealthInfo	Represents information about job health.
ClusterHealthObserver	An observer to observe the cluster health.
ClusterResourceManager	A cluster resource manager which provides a view over the allocatable resources within a Kubernetes cluster and allows to simulate scheduling pods with a defined number of required resources.
ClusterResourceView	A view on Kubernetes cluster resources by nodes and their cpu/memory.
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.
CollectedMetricHistory	Topology and collected metric history.
CollectedMetrics	Collected scaling metrics.
CommonStatus<SPEC extends AbstractFlinkSpec>	Last observed common status of the Flink deployment/Flink SessionJob.
ConfigChanges	Holds the configuration overrides and removals for a Flink Configuration.
ConfigMapStore	The ConfigMapStore persists state in Kubernetes ConfigMaps.
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.
DateTimeUtils	Date and time related utilities.
DefaultFlinkMutator	Default Flink Mutator.
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.
Edge	Collected scaling metrics.
EnvUtils	Util to get value from environments.
EvaluatedMetrics	Collected scaling metrics.
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.
FlinkClusterJobListFetcher	Fetch JobAutoScalerContext based on flink cluster.
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.
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.
FlinkResourceMutator	Mutator for Flink Resources.
FlinkResourceUtils	Utilities for Flink K8S resource.
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.
InformerHealthSummary	Operator informer health summary.
InformerIdentifier	Operator informer identifier.
InformerManager	The manager of the informers.
IngressSpec	Ingress spec.
IngressUtils	Ingress utilities.
InitStandaloneTaskManagerDecorator	An initializer for the TaskManager FlinkPod in standalone mode.
InMemoryAutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>>	State store based on the Java Heap, the state will be discarded after process restarts.
IOMetrics	Vertex io metrics.
IOMetricsInfo	IO metrics information.
JdbcAutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>	The event handler which persists its event in JDBC related database.
JdbcAutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>>	The state store which persists its state in JDBC related database.
JdbcEventInteractor	Responsible for interacting with the database.
JdbcStateInteractor	Responsible for interacting with the database.
JdbcStateStore	The jdbc state store.
JobAutoScaler<KEY,Context extends JobAutoScalerContext<KEY>>	Flink Job AutoScaler.
JobAutoScalerContext<KEY>	The job autoscaler context, it includes all details related to the current job.
JobAutoScalerImpl<KEY,Context extends JobAutoScalerContext<KEY>>	The default implementation of JobAutoScaler.
JobListFetcher<KEY,Context extends JobAutoScalerContext<KEY>>	The JobListFetcher will fetch the jobContext of all jobs.
JobManagerDeploymentStatus	Status of the Flink JobManager Kubernetes deployment.
JobManagerSpec	JobManager spec.
JobSpec	Flink job spec.
JobState	Enum describing the desired job state.
JobStateView	The view of 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<KEY,Context extends JobAutoScalerContext<KEY>>	Component responsible for computing vertex parallelism based on the scaling metrics.
KubernetesAutoScalerEventHandler	An event handler which posts events to the Kubernetes events API.
KubernetesAutoScalerStateStore	An AutoscalerStateStore which persists its state in Kubernetes ConfigMaps.
KubernetesClientMetrics	Kubernetes client metrics.
KubernetesClientUtils	Kubernetes client utils.
KubernetesDeploymentMode	Enum to control Flink deployment mode on Kubernetes.
KubernetesJobAutoScalerContext	An implementation of JobAutoscalerContext for Kubernetes.
KubernetesNodeResourceInfo	A single Kubernetes node and its resources (cpu / memory).
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.
KubernetesResource	A Kubernetes resource and its current allocation.
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.
KubernetesScalingRealizer	The Kubernetes implementation for applying parallelism overrides.
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.
LoadSimulationPipeline	Example pipeline which simulates fluctuating load from zero to a defined max, and vice-versa.
LoggingEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>	Autoscaler event handler which logs events.
MemoryBudget	Accounting for distributing memory over the available pools.
MemoryScaling	Memory scaling ensures that memory is scaled alongside with the number of available TaskManagers.
MemoryTuning	Tunes the TaskManager memory.
MetricAggregator	Enum specifying which aggregator to use when getting a metric value.
MetricManager<CR extends AbstractFlinkResource<?,?>>	Metric manager for Operator managed custom resources.
MetricNotFoundException	Exception for when an expected metric was not found.
MissingJobManagerException	Exception to signal missing job manager.
MissingSessionJobException	Exception to signal missing session job.
Mode	The mode of FlinkDeployment.
MutatorUtils	Mutator utilities.
NativeFlinkService	Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.
NoopJobAutoscaler<KEY,Context extends JobAutoScalerContext<KEY>>	An autoscaler implementation which does nothing.
NoopResourceCheck	Noop implementation for checking for available resources.
NotReadyException	An exception to indicate the called code wasn't ready but will be at a later point in time.
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.
RescaleApiScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>	A ScalingRealizer which uses the Rescale API to apply parallelism changes.
Resource	Resource spec.
ResourceCheck	An interface for checking the available capacity of the underlying resources.
ResourceCheckUtils	Utils methods for resource checks.
ResourceLifecycleMetricTracker	Lifecycle state transition tracker for a single resource.
ResourceLifecycleState	Enum encapsulating the lifecycle state of a Flink resource.
RestApiMetricsCollector<KEY,Context extends JobAutoScalerContext<KEY>>	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.
SavepointTriggerRequestBody	RequestBody to trigger savepoints.
ScalingExecutor<KEY,Context extends JobAutoScalerContext<KEY>>	Class responsible for executing scaling decisions.
ScalingHistoryUtils	The utils for scaling history.
ScalingMetric	Supported scaling metrics.
ScalingMetricCollector<KEY,Context extends JobAutoScalerContext<KEY>>	Metric collector using flink rest api.
ScalingMetricEvaluator	Job scaling evaluator for autoscaler.
ScalingMetrics	Utilities for computing scaling metrics based on Flink metrics.
ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>>	The Scaling Realizer is responsible for applying scaling actions, i.e.
ScalingRecord	Class for tracking scaling details, including time it took for the job to transition to the target parallelism.
ScalingSummary	Scaling summary returned by the ScalingMetricEvaluator.
ScalingTracking	Stores rescaling related information for the job.
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.
ShipStrategy	The ship strategy between 2 JobVertices.
Snapshot	A common interface for Checkpoint and Savepoint.
SnapshotInfo	Interface representing common snapshot information.
SnapshotObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>>	An observer of savepoint progress.
SnapshotStatus	Enum encapsulating the lifecycle state of a Flink snapshot.
SnapshotTriggerType	Snapshot trigger mechanism.
SnapshotType	This enumeration represents the types of state snapshots that can be taken in Flink.
SnapshotUtils	Savepoint utilities.
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.
StandaloneAutoscalerEntrypoint	The entrypoint of the standalone autoscaler.
StandaloneAutoscalerExecutor<KEY,Context extends JobAutoScalerContext<KEY>>	The executor of the standalone autoscaler.
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.
StateType	The state type.
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.
VertexScalingReport	The scaling report of single vertex.