AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> |
Base class for all Flink resource reconcilers.
|
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.
|
ApplicationReconciler |
Reconciler Flink Application deployments.
|
NoopJobAutoscalerFactory |
An autoscaler implementation which does nothing.
|
ReconcilerFactory |
The factory to create reconciler based on app mode.
|
SessionReconciler |
Reconciler responsible for handling the session cluster lifecycle according to the desired and
current states.
|