Uses of Class
org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration

Packages that use FlinkOperatorConfiguration

Package	Description
org.apache.flink.kubernetes.operator.config
org.apache.flink.kubernetes.operator.metrics
org.apache.flink.kubernetes.operator.reconciler
org.apache.flink.kubernetes.operator.utils

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 FlinkOperatorConfiguration	FlinkOperatorConfiguration.fromConfiguration(org.apache.flink.configuration.Configuration operatorConfig)
FlinkOperatorConfiguration	FlinkConfigManager.getOperatorConfiguration()

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.Histogram	OperatorMetricUtils.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 <SPEC extends AbstractFlinkSpec> boolean	ReconciliationUtils.applyValidationErrorAndResetSpec(AbstractFlinkResource<SPEC,?> deployment, java.lang.String validationError, FlinkOperatorConfiguration conf)	In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking.
static java.time.Duration	ReconciliationUtils.rescheduleAfter(JobManagerDeploymentStatus status, FlinkDeployment flinkDeployment, FlinkOperatorConfiguration operatorConfiguration)
static <STATUS extends CommonStatus<?>,R extends AbstractFlinkResource<?,STATUS>> io.javaoperatorsdk.operator.api.reconciler.ErrorStatusUpdateControl<R>	ReconciliationUtils.toErrorStatusUpdateControl(R resource, java.util.Optional<io.javaoperatorsdk.operator.api.reconciler.RetryInfo> retryInfo, java.lang.Exception e, StatusRecorder<R,STATUS> statusRecorder, FlinkOperatorConfiguration operatorConfiguration)	Update the resource error status and metrics when the operator encountered an exception during reconciliation.
static <SPEC extends AbstractFlinkSpec,STATUS extends 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)
static void	ReconciliationUtils.updateForReconciliationError(AbstractFlinkResource<?,?> target, java.lang.Throwable error, FlinkOperatorConfiguration conf)

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.KubernetesClient	KubernetesClientUtils.getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup)
static io.fabric8.kubernetes.client.KubernetesClient	KubernetesClientUtils.getKubernetesClient(FlinkOperatorConfiguration operatorConfig, org.apache.flink.metrics.MetricGroup metricGroup, io.fabric8.kubernetes.client.Config kubernetesClientConfig)
static <R extends AbstractFlinkResource> void	FlinkResourceExceptionUtils.updateFlinkResourceException(java.lang.Throwable throwable, R resource, FlinkOperatorConfiguration conf)