Uses of Class
org.apache.flink.kubernetes.operator.config.FlinkConfigManager
-
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.artifact
Constructors in org.apache.flink.kubernetes.operator.artifact with parameters of type FlinkConfigManager Constructor Description ArtifactManager(FlinkConfigManager configManager)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.controller
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.health
Methods in org.apache.flink.kubernetes.operator.health with parameters of type FlinkConfigManager Modifier and Type Method Description static OperatorHealthService
OperatorHealthService. fromConfig(FlinkConfigManager configManager)
Constructors in org.apache.flink.kubernetes.operator.health with parameters of type FlinkConfigManager Constructor Description OperatorHealthService(FlinkConfigManager configManager)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.listener
Methods in org.apache.flink.kubernetes.operator.listener with parameters of type FlinkConfigManager Modifier and Type Method Description static java.util.Collection<FlinkResourceListener>
ListenerUtils. discoverListeners(FlinkConfigManager configManager)
LoadFlinkResourceListener
implementations from the plugin directory. -
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.metrics
Methods in org.apache.flink.kubernetes.operator.metrics with parameters of type FlinkConfigManager Modifier and Type Method Description static MetricManager<FlinkDeployment>
MetricManager. createFlinkDeploymentMetricManager(FlinkConfigManager configManager, KubernetesOperatorMetricGroup metricGroup)
static MetricManager<FlinkSessionJob>
MetricManager. createFlinkSessionJobMetricManager(FlinkConfigManager configManager, KubernetesOperatorMetricGroup metricGroup)
static KubernetesResourceMetricGroup
OperatorMetricUtils. createResourceMetricGroup(KubernetesOperatorMetricGroup operatorMetricGroup, FlinkConfigManager configManager, AbstractFlinkResource<?,?> resource)
Constructors in org.apache.flink.kubernetes.operator.metrics with parameters of type FlinkConfigManager Constructor Description OperatorJosdkMetrics(KubernetesOperatorMetricGroup operatorMetricGroup, FlinkConfigManager configManager)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.metrics.lifecycle
Constructors in org.apache.flink.kubernetes.operator.metrics.lifecycle with parameters of type FlinkConfigManager Constructor Description LifecycleMetrics(FlinkConfigManager configManager, KubernetesOperatorMetricGroup operatorMetricGroup)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.observer
Fields in org.apache.flink.kubernetes.operator.observer declared as FlinkConfigManager Modifier and Type Field Description protected FlinkConfigManager
AbstractFlinkResourceObserver. configManager
protected FlinkConfigManager
JobStatusObserver. configManager
Constructors in org.apache.flink.kubernetes.operator.observer with parameters of type FlinkConfigManager Constructor Description AbstractFlinkResourceObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
JobStatusObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
SavepointObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.observer.deployment
Constructors in org.apache.flink.kubernetes.operator.observer.deployment with parameters of type FlinkConfigManager Constructor Description AbstractFlinkDeploymentObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
ApplicationObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
FlinkDeploymentObserverFactory(FlinkConfigManager configManager, EventRecorder eventRecorder)
SessionObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.observer.sessionjob
Constructors in org.apache.flink.kubernetes.operator.observer.sessionjob with parameters of type FlinkConfigManager Constructor Description FlinkSessionJobObserver(FlinkConfigManager configManager, EventRecorder eventRecorder)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.reconciler.deployment
Constructors in org.apache.flink.kubernetes.operator.reconciler.deployment with parameters of type FlinkConfigManager Constructor Description ReconcilerFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> deploymentStatusRecorder, JobAutoScalerFactory autoscalerFactory)
SessionReconciler(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, EventRecorder eventRecorder, StatusRecorder<FlinkDeployment,FlinkDeploymentStatus> statusRecorder, FlinkConfigManager configManager)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.service
Fields in org.apache.flink.kubernetes.operator.service declared as FlinkConfigManager Modifier and Type Field Description protected FlinkConfigManager
AbstractFlinkService. configManager
Constructors in org.apache.flink.kubernetes.operator.service with parameters of type FlinkConfigManager Constructor Description AbstractFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager)
FlinkResourceContextFactory(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager, KubernetesOperatorMetricGroup operatorMetricGroup)
NativeFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager)
StandaloneFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, FlinkConfigManager configManager)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type FlinkConfigManager Modifier and Type Method Description static java.util.Set<FlinkResourceValidator>
ValidatorUtils. discoverValidators(FlinkConfigManager configManager)
-
Uses of FlinkConfigManager in org.apache.flink.kubernetes.operator.validation
Constructors in org.apache.flink.kubernetes.operator.validation with parameters of type FlinkConfigManager Constructor Description DefaultValidator(FlinkConfigManager configManager)
-