Uses of Class
org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration
-
-
Uses of FlinkOperatorConfiguration in org.apache.flink.kubernetes.operator.config
Methods in org.apache.flink.kubernetes.operator.config that return FlinkOperatorConfiguration Modifier and Type Method Description static FlinkOperatorConfigurationFlinkOperatorConfiguration. fromConfiguration(org.apache.flink.configuration.Configuration operatorConfig)FlinkOperatorConfigurationFlinkConfigManager. getOperatorConfiguration()FlinkOperatorConfigurationFlinkConfigManager. getOperatorConfiguration(java.lang.String namespace, org.apache.flink.kubernetes.operator.api.spec.FlinkVersion flinkVersion)Get the operator configuration for the given namespace and flink version combination. -
Uses of FlinkOperatorConfiguration in org.apache.flink.kubernetes.operator.controller
Methods in org.apache.flink.kubernetes.operator.controller that return FlinkOperatorConfiguration Modifier and Type Method Description FlinkOperatorConfigurationFlinkResourceContext. getOperatorConfig() -
Uses of FlinkOperatorConfiguration in org.apache.flink.kubernetes.operator.metrics
Methods in org.apache.flink.kubernetes.operator.metrics with parameters of type FlinkOperatorConfiguration Modifier and Type Method Description static org.apache.flink.metrics.HistogramOperatorMetricUtils. createHistogram(FlinkOperatorConfiguration operatorConfiguration)Constructors in org.apache.flink.kubernetes.operator.metrics with parameters of type FlinkOperatorConfiguration Constructor Description KubernetesClientMetrics(org.apache.flink.metrics.MetricGroup parentGroup, FlinkOperatorConfiguration flinkOperatorConfiguration) -
Uses of FlinkOperatorConfiguration in org.apache.flink.kubernetes.operator.reconciler
Methods in org.apache.flink.kubernetes.operator.reconciler with parameters of type FlinkOperatorConfiguration Modifier and Type Method Description static java.time.DurationReconciliationUtils. rescheduleAfter(org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus status, org.apache.flink.kubernetes.operator.api.FlinkDeployment flinkDeployment, FlinkOperatorConfiguration operatorConfiguration)static <SPEC extends org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec,STATUS extends org.apache.flink.kubernetes.operator.api.status.CommonStatus<SPEC>,R extends io.fabric8.kubernetes.client.CustomResource<SPEC,STATUS>>
io.javaoperatorsdk.operator.api.reconciler.UpdateControl<R>ReconciliationUtils. toUpdateControl(FlinkOperatorConfiguration operatorConfiguration, R current, R previous, boolean reschedule) -
Uses of FlinkOperatorConfiguration in org.apache.flink.kubernetes.operator.service
Fields in org.apache.flink.kubernetes.operator.service declared as FlinkOperatorConfiguration Modifier and Type Field Description protected FlinkOperatorConfigurationAbstractFlinkService. operatorConfigConstructors in org.apache.flink.kubernetes.operator.service with parameters of type FlinkOperatorConfiguration Constructor Description AbstractFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, ArtifactManager artifactManager, java.util.concurrent.ExecutorService executorService, FlinkOperatorConfiguration operatorConfig)NativeFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, ArtifactManager artifactManager, java.util.concurrent.ExecutorService executorService, FlinkOperatorConfiguration operatorConfig, EventRecorder eventRecorder)StandaloneFlinkService(io.fabric8.kubernetes.client.KubernetesClient kubernetesClient, ArtifactManager artifactManager, java.util.concurrent.ExecutorService executorService, FlinkOperatorConfiguration operatorConfig) -
Uses of FlinkOperatorConfiguration in org.apache.flink.kubernetes.operator.utils
Methods in org.apache.flink.kubernetes.operator.utils with parameters of type FlinkOperatorConfiguration Modifier and Type Method Description static io.fabric8.kubernetes.client.KubernetesClientKubernetesClientUtils. getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup)static io.fabric8.kubernetes.client.KubernetesClientKubernetesClientUtils. getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup, io.fabric8.kubernetes.client.Config kubernetesClientConfig)static <R extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource>
voidFlinkResourceExceptionUtils. updateFlinkResourceException(java.lang.Throwable throwable, R resource, FlinkOperatorConfiguration conf)
-