A B C D E F G H I J K L M N O P Q R S T U V W Y
All Classes All Packages

A

ABANDONED - org.apache.flink.kubernetes.operator.utils.SavepointStatus

Manual savepoint is abandoned after defined retries.

AbstractFlinkDeploymentObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment

Base observer for session and application clusters.

AbstractFlinkDeploymentObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

AbstractFlinkResource<SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.api

Abstract base class Flink resources.

AbstractFlinkResource() - Constructor for class org.apache.flink.kubernetes.operator.api.AbstractFlinkResource

AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.observer

Base observer for all Flink resources.

AbstractFlinkResourceObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Base class for all Flink resource reconcilers.

AbstractFlinkResourceReconciler(KubernetesClient, EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

AbstractFlinkService - Class in org.apache.flink.kubernetes.operator.service

An abstract FlinkService containing some common implementations for the native and standalone Flink Services.

AbstractFlinkService(KubernetesClient, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

AbstractFlinkSpec - Class in org.apache.flink.kubernetes.operator.api.spec

The common spec.

AbstractFlinkSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec

AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Reconciler responsible for handling the job lifecycle according to the desired and current states.

AbstractJobReconciler(KubernetesClient, EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

AbstractJobReconciler.AvailableUpgradeMode - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Object to capture available upgrade mode.

addToScalingHistory(Instant, Map<JobVertexID, ScalingSummary>, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

AdmissionHandler - Class in org.apache.flink.kubernetes.operator.admission

Rest endpoint for validation requests.

AdmissionHandler(Validator<HasMetadata>, Mutator<HasMetadata>) - Constructor for class org.apache.flink.kubernetes.operator.admission.AdmissionHandler

admissionResponseFromMutation(KubernetesResource, KubernetesResource) - Static method in class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator

allCanariesHealthy() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

allVerticesWithinUtilizationTarget(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

API_GROUP - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants

API_VERSION - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants

append(String, boolean[], boolean[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, boolean, boolean, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, byte[], byte[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, byte, byte, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, char[], char[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, char, char, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, double[], double[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, double, double, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, float[], float[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, float, float, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, int[], int[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, int, int, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, long[], long[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, long, long, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, short[], short[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, short, short, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, DiffResult<?>) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, Object[], Object[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

append(String, Object, Object, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

APPLICATION - org.apache.flink.kubernetes.operator.config.Mode

APPLICATION - org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode

APPLICATION_MODE_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator

ApplicationObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment

The observer of Mode.APPLICATION cluster.

ApplicationObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver

applicationProtocolNegotiator() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

ApplicationReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Reconciler Flink Application deployments.

ApplicationReconciler(KubernetesClient, EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

applyCommonPodTemplate() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyFlinkConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyImage() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyImagePullPolicy() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyIngressDomain() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyJobManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyJobOrSessionSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyLogConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyResourceToPodTemplate(Pod, Resource) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyServiceAccount() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyTaskManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

applyToStoredCr(KubernetesClient, T, Consumer<T>) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

applyValidationErrorAndResetSpec(AbstractFlinkResource<SPEC, ?>, String, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

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.

ArtifactFetcher - Interface in org.apache.flink.kubernetes.operator.artifact

The artifact fetcher.

artifactManager - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

ArtifactManager - Class in org.apache.flink.kubernetes.operator.artifact

Manage the user artifacts.

ArtifactManager(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.artifact.ArtifactManager

AuditUtils - Class in org.apache.flink.kubernetes.operator.listener

Responsible for logging resource event/status updates.

AuditUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.AuditUtils

AUTOSCALER_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

AutoscalerError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

AutoscalerFlinkMetrics - Class in org.apache.flink.kubernetes.operator.autoscaler

Autoscaler metrics for observability.

AutoscalerFlinkMetrics(MetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFlinkMetrics

AutoScalerInfo - Class in org.apache.flink.kubernetes.operator.autoscaler

Class for encapsulating information stored for each resource when using the autoscaler.

AutoScalerInfo(ConfigMap) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

AutoScalerInfo(Map<String, String>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

AutoscalerLoader - Class in org.apache.flink.kubernetes.operator.utils

Loads the active Autoscaler implementation from the classpath.

AutoscalerLoader() - Constructor for class org.apache.flink.kubernetes.operator.utils.AutoscalerLoader

AutoScalerOptions - Class in org.apache.flink.kubernetes.operator.autoscaler.config

Config options related to the autoscaler module.

AutoScalerOptions() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

AutoScalerSerDeModule - Class in org.apache.flink.kubernetes.operator.autoscaler.utils

Jackson serializer module for JobVertexID.

AutoScalerSerDeModule() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.utils.AutoScalerSerDeModule

AutoScalerUtils - Class in org.apache.flink.kubernetes.operator.autoscaler.utils

AutoScaler utilities.

AutoScalerUtils() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.utils.AutoScalerUtils

autoscaling - package autoscaling

AutoscalingExample - Class in autoscaling

Autoscaling Example.

AutoscalingExample() - Constructor for class autoscaling.AutoscalingExample

AvailableUpgradeMode() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode

AVG - org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator

B

BACKLOG_PROCESSING_LAG_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

build() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

build() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

build() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder

buildFrom(String, String, FlinkDeploymentSpec, Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

buildKubernetesJobManagerSpecification(FlinkPod, StandaloneKubernetesJobManagerParameters) - Static method in class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory

buildKubernetesTaskManagerDeployment(FlinkPod, StandaloneKubernetesTaskManagerParameters) - Static method in class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesTaskManagerFactory

BUSY_TIME_AGGREGATOR - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

BUSY_TIME_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

C

calculateClusterCpuUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

calculateClusterMemoryUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

CANARY_LABEL - Static variable in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

CANARY_RESOURCE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

CanaryResourceManager<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.health

Logic encapsulating canary tests.

CanaryResourceManager() - Constructor for class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

cancelJob(FlinkDeployment, UpgradeMode, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

cancelJob(FlinkResourceContext<CR>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

Cancel the job for the given resource using the specified upgrade mode.

cancelJob(FlinkResourceContext<FlinkDeployment>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

cancelJob(FlinkResourceContext<FlinkSessionJob>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

cancelSessionJob(FlinkSessionJob, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

cancelSessionJob(FlinkSessionJob, UpgradeMode, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

CANONICAL - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType

A canonical, common for all state backends format.

CATCH_UP_DATA_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Target processing rate of operators as derived from backlog (records/sec).

CATCH_UP_DURATION - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

changeLastStateIfCheckpointTooOld(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler

channelRead0(ChannelHandlerContext, HttpRequest) - Method in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler

checkAndUpdateStableSpec(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Checks the status and if the corresponding Flink job/application is in stable running state, it updates the last stable spec.

checkHealth(ResourceID) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

checkObjectCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker

CheckpointHistoryWrapper - Class in org.apache.flink.kubernetes.operator.service

Custom Response for handling checkpoint history in a multi-version compatible way.

CheckpointHistoryWrapper() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

CheckpointHistoryWrapper.CompletedCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service

Information about the latest completed checkpoint/savepoint.

CheckpointHistoryWrapper.PendingCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service

Information about the currently pending checkpoint/savepoint.

checkStringTypeCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker

checkTypeCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker

cipherSuites() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

cleanup(CR) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

cleanup(AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobAutoScalerImpl

cleanup(AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

cleanup(AbstractFlinkResource<?, ?>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.deployment.JobAutoScaler

Called when the custom resource is deleted.

cleanup(AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory

cleanup(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

cleanup(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

cleanup(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

cleanup(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler

This is called when receiving the delete event of custom resource.

Cleanup - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

cleanupAfterFailedJob(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

Removes a failed job.

cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

cleanupAfterFailedJob(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

cleanupDoneFor(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

CleanupFailed - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

cleanupInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Shut down and clean up all Flink job/cluster resources.

cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

cleanupInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

cleanupTmpFiles(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

clearErrorsIfDeploymentIsHealthy(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

clearLastReconciledSpecIfFirstDeploy(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Clear last reconciled spec if that corresponds to the first deployment.

clearMetricHistory() - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

clock - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

clone(T) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils

clone(T) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

CLUSTER_MODE - Static variable in class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal

ClusterHealthEvaluator - Class in org.apache.flink.kubernetes.operator.observer

Evaluates whether the cluster is healthy.

ClusterHealthEvaluator(Clock) - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

ClusterHealthInfo - Class in org.apache.flink.kubernetes.operator.health

Represents information about job health.

ClusterHealthInfo() - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

ClusterHealthInfo(Clock) - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

ClusterHealthObserver - Class in org.apache.flink.kubernetes.operator.observer

An observer to observe the cluster health.

ClusterHealthObserver() - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver

clusterShutdownDisabled(FlinkDeploymentSpec) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

CmdStandaloneJobManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators

Attach the command and args to the main container for running the JobManager in standalone mode.

CmdStandaloneJobManagerDecorator(StandaloneKubernetesJobManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator

CmdStandaloneTaskManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators

Attach the command and args to the main container for running the TaskManager in standalone mode.

CmdStandaloneTaskManagerDecorator(StandaloneKubernetesTaskManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator

COLLECTED_METRICS_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

CollectedMetricHistory - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics

Topology and collected metric history.

CollectedMetricHistory() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.CollectedMetricHistory

CollectedMetrics - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics

Collected scaling metrics.

CollectedMetrics() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.CollectedMetrics

CommonStatus<SPEC extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.status

Last observed common status of the Flink deployment/Flink SessionJob.

CommonStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.CommonStatus

CompatibilityError(String) - Constructor for exception org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.CompatibilityError

completed(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

CompletedCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.CompletedCheckpointInfo

computeDataRateMetrics(JobVertexID, Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>, JobTopology, double, Configuration) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics

computeLagMetrics(Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics

computeLoadMetrics(Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics

computeOutputRatios(Map<JobVertexID, Map<FlinkMetric, AggregatedMetric>>, JobTopology) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics

computeProcessingRateThresholds(Map<ScalingMetric, EvaluatedScalingMetric>, Configuration, boolean) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator

computeScaleTargetParallelism(AbstractFlinkResource<?, ?>, Configuration, JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>, SortedMap<Instant, ScalingSummary>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler

configManager - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

configManager - Variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

configManager - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

ConfigOptionsDocGenerator - Class in org.apache.flink.kubernetes.operator.docs.configuration

Class used for generating code based documentation of configuration parameters.

ConfigOptionUtils - Class in org.apache.flink.kubernetes.operator.utils

ConfigOption utilities.

ConfigOptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils

COUNTER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

COUNTER_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

COUNTER_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

CPU_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

CR_GENERATION_LABEL - Static variable in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

CrdCompatibilityChecker - Class in org.apache.flink.kubernetes.operator.api.validation

Utility for checking backward CRD compatibility.

CrdCompatibilityChecker() - Constructor for class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker

CrdCompatibilityChecker.CompatibilityError - Exception in org.apache.flink.kubernetes.operator.api.validation

Compatibility Error class.

CrdConstants - Class in org.apache.flink.kubernetes.operator.api

Constants used by the CRD.

CrdConstants() - Constructor for class org.apache.flink.kubernetes.operator.api.CrdConstants

CrdReferenceDoclet - Class in org.apache.flink.kubernetes.operator.api.docs

Doclet for generating the FlinkDeployment CRD reference.

CrdReferenceDoclet() - Constructor for class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet

create(KubernetesClient, Collection<FlinkResourceListener>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

create(KubernetesClient, MetricManager<CR>, Collection<FlinkResourceListener>) - Static method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

create(KubernetesClient, EventRecorder) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobAutoscalerFactoryImpl

create(KubernetesClient, EventRecorder) - Method in interface org.apache.flink.kubernetes.operator.reconciler.deployment.JobAutoScalerFactory

create(KubernetesClient, EventRecorder) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory

create(Configuration, ExecutorService) - Static method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient

create(MetricRegistry, Configuration, String, String, String) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

CREATED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

createFlinkDeploymentMetricManager(FlinkConfigManager, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

createFlinkSessionJobMetricManager(FlinkConfigManager, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

createHistogram(FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

createMetricConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

createNamespacedKubeClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Generate the config that is currently deployed for the resource spec.

createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

createOperator() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

createOrUpdateEvent(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

createResourceGroup(Configuration, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

createResourceMetricGroup(KubernetesOperatorMetricGroup, FlinkConfigManager, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

createResourceNamespaceGroup(Configuration, Class<? extends AbstractFlinkResource>, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

createSavepointError(SavepointInfo, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

createTaskManagerDeployment(Deployment) - Method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient

createTaskManagerDeployment(Deployment) - Method in interface org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient

current() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

Returns the current version.

CURRENT_PROCESSING_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Current processing rate.

CustomCheckpointingStatisticsHeaders - Class in org.apache.flink.kubernetes.operator.service

Custom Headers for handling checkpoint history in a multi-version compatible way.

CustomCheckpointingStatisticsHeaders() - Constructor for class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

CustomDashboardConfiguration - Class in org.apache.flink.kubernetes.operator.service

Custom Response for handling dashboard configs.

CustomDashboardConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration

CustomDashboardConfigurationHeaders - Class in org.apache.flink.kubernetes.operator.service

Message headers for the CustomDashboardConfiguration.

CustomResourceMetrics<CR extends io.fabric8.kubernetes.client.CustomResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.metrics

Custom resource metric type.

D

dec() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

dec(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator

decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator

decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.InitStandaloneTaskManagerDecorator

decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.UserLibMountDecorator

DEFAULT_CHECKPOINTING_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

DefaultRequestMutator<T extends io.fabric8.kubernetes.api.model.KubernetesResource> - Class in org.apache.flink.kubernetes.operator.admission.mutator

The default request mutator.

DefaultRequestMutator(Mutator<T>) - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator

DefaultRequestMutator(Mutator<T>, Cloner<T>) - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator

DefaultValidator - Class in org.apache.flink.kubernetes.operator.validation

Default validator implementation for FlinkDeployment.

DefaultValidator(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.validation.DefaultValidator

deleteClusterDeployment(ObjectMeta, FlinkDeploymentStatus, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

deleteClusterDeployment(ObjectMeta, FlinkDeploymentStatus, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

Delete Flink kubernetes cluster by deleting the kubernetes resources directly.

deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

deleteHAData(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

deleteJobGraphInKubernetesHA(String, String, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deleteJobGraphInZookeeperHA(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deleteKubernetesHAMetadata(String, String, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deleteZookeeperHAMetadata(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

deploy(FlinkResourceContext<CR>, SPEC, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Deploys the target resource spec to Kubernetes.

deploy(FlinkResourceContext<FlinkDeployment>, FlinkDeploymentSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

deploy(FlinkResourceContext<FlinkDeployment>, FlinkDeploymentSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

deploy(FlinkResourceContext<FlinkSessionJob>, FlinkSessionJobSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

deployApplicationCluster(ClusterSpecification, ApplicationConfiguration) - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor

deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

DEPLOYED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

DEPLOYED - org.apache.flink.kubernetes.operator.api.status.ReconciliationState

The lastReconciledSpec is currently deployed.

DEPLOYED_NOT_READY - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

JobManager is running but not ready yet to receive REST API calls.

DEPLOYING - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

JobManager process is starting up.

DEPLOYMENT_READINESS_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

DEPLOYMENT_ROLLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

DeploymentFailedException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal terminal deployment failure.

DeploymentFailedException(DeploymentCondition) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

DeploymentFailedException(ContainerStateWaiting) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

DeploymentFailedException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

deploySessionCluster(ClusterSpecification) - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor

deserialize(String) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

deserializeLastReconciledSpec() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

deserializeLastReconciledSpecWithMeta() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

deserializeLastStableSpec() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

deserializeLastStableSpecWithMeta() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

deserializeSpecWithMeta(String, Class<T>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils

Deserializes the spec and custom metadata object from JSON.

Diff<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Contains the differences between two Diffable class fields.

Diff() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.Diff

Diffable<T> - Interface in org.apache.flink.kubernetes.operator.api.diff

Diffable classes can be compared with other Diffable objects for differences.

DiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Assists in implementing comparison of Diffable instances.

DiffBuilder(T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

DiffResult<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Contains a collection of the differences between two Diffable objects.

DiffType - Enum in org.apache.flink.kubernetes.operator.api.diff

Spec change type.

discoverListeners(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils

Load FlinkResourceListener implementations from the plugin directory.

discoverValidators(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils

disposeSavepoint(String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

disposeSavepoint(String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

E

Edge - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics

Collected scaling metrics.

Edge() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.Edge

ENV_CONF_OVERRIDE_DIR - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_HOSTNAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_KUBERNETES_SERVICE_HOST - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_OPERATOR_NAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_OPERATOR_NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WATCH_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_KEYSTORE_FILE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_KEYSTORE_PASSWORD - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_KEYSTORE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

ENV_WEBHOOK_SERVER_PORT - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils

EnvUtils - Class in org.apache.flink.kubernetes.operator.utils

Util to get value from environments.

EnvUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EnvUtils

EPHEMERAL_STORAGE - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants

equals(Object) - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

error(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

ERROR - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

Deployment in terminal error, requires spec change for reconciliation to continue.

escapeCharacters(String) - Static method in class org.apache.flink.kubernetes.operator.docs.util.Utils

evaluate(Configuration, Map<String, String>, ClusterHealthInfo) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

evaluate(Configuration, CollectedMetricHistory) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator

EvaluatedScalingMetric - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics

Evaluated scaling metric.

EvaluatedScalingMetric(double, double) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.EvaluatedScalingMetric

eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

eventRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

EventRecorder - Class in org.apache.flink.kubernetes.operator.utils

Helper class for creating Kubernetes events for Flink resources.

EventRecorder(KubernetesClient, BiConsumer<AbstractFlinkResource<?, ?>, Event>) - Constructor for class org.apache.flink.kubernetes.operator.utils.EventRecorder

EventRecorder.Component - Enum in org.apache.flink.kubernetes.operator.utils

The component of events.

EventRecorder.Reason - Enum in org.apache.flink.kubernetes.operator.utils

The reason codes of events.

EventRecorder.Type - Enum in org.apache.flink.kubernetes.operator.utils

The type of the events.

EventSourceUtils - Class in org.apache.flink.kubernetes.operator.utils

Utility class to locate secondary resources.

EventSourceUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

EventUtils - Class in org.apache.flink.kubernetes.operator.utils

The util to generate an event for the target resource.

EventUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventUtils

EXPECTED_PROCESSING_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Expected true processing rate after scale up.

F

Fabric8FlinkStandaloneKubeClient - Class in org.apache.flink.kubernetes.operator.kubeclient

The Implementation of FlinkStandaloneKubeClient.

Fabric8FlinkStandaloneKubeClient(Configuration, NamespacedKubernetesClient, ExecutorService) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient

FAILED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

failedReconciliation(ResourceID, Exception, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

fetch(String, Configuration, File) - Method in interface org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher

Fetch the resource from the uri to the targetDir.

fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

fetch(String, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager

fetchSavepointInfo(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

fetchSavepointInfo(String, String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

FIELD_NAME_ACC_BACK_PRESSURE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_ACC_BUSY - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_ACC_IDLE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_BYTES_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_BYTES_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_FLINK_REVISION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration

FIELD_NAME_FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration

FIELD_NAME_FORMAT_TYPE - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

FIELD_NAME_RECORDS_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_RECORDS_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

FIELD_NAME_TOTAL_CPU - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

FIELD_NAME_TOTAL_MEMORY - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

FileSystemBasedArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact

Leverage the flink filesystem plugin to fetch the artifact.

FileSystemBasedArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

FileSystemWatchService - Class in org.apache.flink.kubernetes.operator.fs

Service which is able to watch local filesystem directories.

FileSystemWatchService(String) - Constructor for class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

filterTargetJob(JobStatus, List<JobStatusMessage>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Filter the target job status message by the job list from the cluster.

findAny(Collection<AggregatedMetric>) - Method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

finishedReconciliation(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

FLINK_VERSION_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

FlinkConfigBuilder - Class in org.apache.flink.kubernetes.operator.config

Builder to get effective flink config from FlinkDeployment.

FlinkConfigBuilder(String, String, FlinkDeploymentSpec, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

FlinkConfigBuilder(FlinkDeployment, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

FlinkConfigManager - Class in org.apache.flink.kubernetes.operator.config

Configuration manager for the Flink operator.

FlinkConfigManager(Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

FlinkConfigManager(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

FlinkConfigManager(Configuration, Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

FlinkDeployment - Class in org.apache.flink.kubernetes.operator.api

Custom resource definition that represents both Application and Session deployments.

FlinkDeployment() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkDeployment

FlinkDeploymentContext - Class in org.apache.flink.kubernetes.operator.controller

Context for reconciling a Flink resource.

FlinkDeploymentContext(FlinkDeployment, Context<?>, KubernetesResourceMetricGroup, FlinkService, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

FlinkDeploymentController - Class in org.apache.flink.kubernetes.operator.controller

Controller that runs the main reconcile loop for Flink deployments.

FlinkDeploymentController(FlinkConfigManager, Set<FlinkResourceValidator>, FlinkResourceContextFactory, ReconcilerFactory, FlinkDeploymentObserverFactory, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, EventRecorder, CanaryResourceManager<FlinkDeployment>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

FlinkDeploymentList - Class in org.apache.flink.kubernetes.operator.api

Multiple Flink deployments.

FlinkDeploymentList() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkDeploymentList

FlinkDeploymentMetrics - Class in org.apache.flink.kubernetes.operator.metrics

FlinkDeployment metrics.

FlinkDeploymentMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

FlinkDeploymentObserverFactory - Class in org.apache.flink.kubernetes.operator.observer.deployment

The factory to create the observer based on the FlinkDeployment mode.

FlinkDeploymentObserverFactory(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory

FlinkDeploymentReconciliationStatus - Class in org.apache.flink.kubernetes.operator.api.status

Status of the last reconcile step for the flink deployment.

FlinkDeploymentReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentReconciliationStatus

FlinkDeploymentSpec - Class in org.apache.flink.kubernetes.operator.api.spec

Spec that describes a Flink application or session cluster deployment.

FlinkDeploymentSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec

FlinkDeploymentStatus - Class in org.apache.flink.kubernetes.operator.api.status

Last observed status of the Flink deployment.

FlinkDeploymentStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus

FlinkMetric - Enum in org.apache.flink.kubernetes.operator.autoscaler.metrics

Enum representing the collected Flink metrics for autoscaling.

FlinkMutator - Class in org.apache.flink.kubernetes.operator.admission.mutator

The default mutator.

FlinkMutator() - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator

FlinkOperator - Class in org.apache.flink.kubernetes.operator

Main Class for Flink native k8s operator.

FlinkOperator(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.FlinkOperator

FlinkOperatorConfiguration - Class in org.apache.flink.kubernetes.operator.config

Configuration class for operator.

FlinkOperatorConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration

FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration - Class in org.apache.flink.kubernetes.operator.config

Enables configurable retry mechanism for reconciliation errors.

FlinkOperatorRetryConfiguration(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration

FlinkOperatorWebhook - Class in org.apache.flink.kubernetes.operator.admission

Main Class for Flink native k8s operator.

FlinkOperatorWebhook() - Constructor for class org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook

FlinkResourceContext<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.controller

Context for reconciling a Flink resource.

FlinkResourceContext() - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

FlinkResourceContextFactory - Class in org.apache.flink.kubernetes.operator.service

Factory for creating the FlinkResourceContext.

FlinkResourceContextFactory(KubernetesClient, FlinkConfigManager, KubernetesOperatorMetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

FlinkResourceException - Class in org.apache.flink.kubernetes.operator.exception

Exception to display as JSON in CRD.

FlinkResourceException() - Constructor for class org.apache.flink.kubernetes.operator.exception.FlinkResourceException

FlinkResourceExceptionUtils - Class in org.apache.flink.kubernetes.operator.utils

Flink Resource Exception utilities.

FlinkResourceExceptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

FlinkResourceListener - Interface in org.apache.flink.kubernetes.operator.api.listener

Listener interface for Flink resource related events and status changes.

FlinkResourceListener.ResourceContext<R extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.api.listener

Base for Resource Event and StatusUpdate contexts.

FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.api.listener

Context for Resource Event listener methods.

FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>> - Interface in org.apache.flink.kubernetes.operator.api.listener

Context for Status listener methods.

FlinkResourceValidator - Interface in org.apache.flink.kubernetes.operator.validation

Validator for different resources.

FlinkService - Interface in org.apache.flink.kubernetes.operator.service

Service for submitting and interacting with Flink clusters and jobs.

FlinkSessionJob - Class in org.apache.flink.kubernetes.operator.api

Custom resource definition that represents a flink session job.

FlinkSessionJob() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkSessionJob

FlinkSessionJobContext - Class in org.apache.flink.kubernetes.operator.controller

Context for reconciling a Flink resource.

FlinkSessionJobContext(FlinkSessionJob, Context<?>, KubernetesResourceMetricGroup, FlinkResourceContextFactory, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

FlinkSessionJobController - Class in org.apache.flink.kubernetes.operator.controller

Controller that runs the main reconcile loop for FlinkSessionJob.

FlinkSessionJobController(FlinkConfigManager, Set<FlinkResourceValidator>, FlinkResourceContextFactory, Reconciler<FlinkSessionJob>, Observer<FlinkSessionJob>, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, EventRecorder, CanaryResourceManager<FlinkSessionJob>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

FlinkSessionJobList - Class in org.apache.flink.kubernetes.operator.api

Multiple Flink session jobs.

FlinkSessionJobList() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkSessionJobList

FlinkSessionJobMetrics - Class in org.apache.flink.kubernetes.operator.metrics

FlinkSessionJob metrics.

FlinkSessionJobMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

FlinkSessionJobObserver - Class in org.apache.flink.kubernetes.operator.observer.sessionjob

The observer of FlinkSessionJob.

FlinkSessionJobObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

FlinkSessionJobReconciliationStatus - Class in org.apache.flink.kubernetes.operator.api.status

Status of the last reconcile step for the flink sessionjob.

FlinkSessionJobReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobReconciliationStatus

FlinkSessionJobSpec - Class in org.apache.flink.kubernetes.operator.api.spec

Spec that describes a Flink session job.

FlinkSessionJobSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec

FlinkSessionJobStatus - Class in org.apache.flink.kubernetes.operator.api.status

Last observed status of the Flink Session job.

FlinkSessionJobStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus

FlinkStandaloneKubeClient - Interface in org.apache.flink.kubernetes.operator.kubeclient

Extension of the FlinkKubeClient that is used for Flink standalone deployments.

FlinkUtils - Class in org.apache.flink.kubernetes.operator.utils

Flink Utility methods used by the operator.

FlinkUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkUtils

FlinkValidator - Class in org.apache.flink.kubernetes.operator.admission

Validator for FlinkDeployment creation and updates.

FlinkValidator(Set<FlinkResourceValidator>, InformerManager) - Constructor for class org.apache.flink.kubernetes.operator.admission.FlinkValidator

FlinkVersion - Enum in org.apache.flink.kubernetes.operator.api.spec

Enumeration for supported Flink versions.

flinkVersionChanged(SPEC, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

format(Event) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils

formatScope(String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

formatScope(String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

formatScope(String, String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

forResource(AbstractFlinkResource<?, ?>, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

from - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

from(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata

fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

fromConfig(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService

fromConfiguration(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration

fromJsonPlan(String, Map<JobVertexID, Integer>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

fromRuntimeInfo(RuntimeInfo) - Static method in class org.apache.flink.kubernetes.operator.health.InformerHealthSummary

G

GENERATED_FILE_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

generateEventName(HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

generateJarDir(ObjectMeta, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager

generateSessionJobFixedJobID(ObjectMeta) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

The jobID's lower part is the resource uid, the higher part is the resource generation.

generateSessionJobFixedJobID(String, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

The jobID's lower part is the resource uid, the higher part is the resource generation.

get(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Get the value provided by environments.

get(AggregatedMetric) - Method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator

getAccumulatedBackpressured() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getAccumulatedBusy() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getAccumulatedIdle() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getAllowNonRestoredState() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getAnnotations() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getAvailableUpgradeMode(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

getAvailableUpgradeMode(FlinkResourceContext<FlinkDeployment>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

getAvailableVertexMetricNames() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

getBytesRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getBytesWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getCache() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getCheckpointInfo(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getCheckpointInfo(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getClearedStatesAfterTransition(ResourceLifecycleState) - Method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

getClusterClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getClusterClient(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getClusterDescription() - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor

getClusterInfo(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getClusterInfo(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getCommonLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getCommonLabels(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

getCpuLimitFactor() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getCurrentState() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

getDefaultConfig() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getDeployConfig(ObjectMeta, FlinkDeploymentSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get Flink configuration object for deploying the given spec using AbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean).

getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

getDeployedGeneration(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

getDeployedSpec(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

getDeploymentInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

getDeploymentMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode

getDeploymentMode(FlinkDeploymentSpec) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode

getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getEffectiveStatus(JobDetails) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getEnvironments() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getEvent() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext

getFilteredVertexMetricNames(RestClusterClient<?>, JobID, JobVertexID, JobTopology) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

Query and filter metric names for a given job vertex.

getFlinkDepInformer(String) - Method in class org.apache.flink.kubernetes.operator.admission.informer.InformerManager

getFlinkDeploymentInformerEventSource(EventSourceContext<FlinkSessionJob>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

getFlinkResource() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext

getFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get the FlinkService implementation for the current resource.

getFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext

getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

getHistories() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getIngressUrl(String, String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils

getInitialInterval() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration

getInProgressCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getIntervalMultiplier() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration

getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

getJmPodList(FlinkDeployment, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getJmPodList(FlinkDeployment, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getJobManagerDeploymentName(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

getJobManagerSelectors(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

getJobSpecArgs() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getJobTopology(FlinkService, AbstractFlinkResource<?, ?>, Configuration, AutoScalerInfo) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext

getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getKubernetesClient(FlinkOperatorConfiguration, MetricGroup) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

getKubernetesClient(FlinkOperatorConfiguration, MetricGroup, Config) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

getLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getLastCheckpoint(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getLastCheckpoint(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getLastSavepointStatus(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

getLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

getLatestCompletedCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper

getLifecycleState() - Method in class org.apache.flink.kubernetes.operator.api.status.CommonStatus

getLifecycleTrackers() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

getMainClass() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getMaxAttempts() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration

getMaxInterval() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration

getMemoryLimitFactor() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getMetricHistory() - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

getMetrics(Configuration, String, List<String>) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getMetrics(Configuration, String, List<String>) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

getMetricWindowSize(Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

getMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode

Return the mode of the given FlinkDeployment for Observer and Reconciler.

getName() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet

getNewStatus() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext

getNodeSelector() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getNumberOfActiveCanaries() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

getNumDiffs() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult

getNumTaskManagers(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

getNumTaskManagers(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

getObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

Get the config that is currently deployed for the resource spec.

getObserveConfig(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getOperatorConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory

getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory

getOrCreateFlinkService(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

getOrDefault(String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Get the value or default value provided by environments.

getOwnerReference() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getPodTemplateFilePath() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getPreviousStatus() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext

getRate() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException

getReconciliationStatus() - Method in class org.apache.flink.kubernetes.operator.api.status.CommonStatus

Current reconciliation status of this resource.

getRecordsRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getRecordsWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

getRegisteredMetrics() - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

getReplicas() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getRequestClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getRequestClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getRequired(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Get the value provided by environments.

getResourceContext(CR, Context) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getRPCPort() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getSavepointFormatType(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

getSavepointPath() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getScalingHistory(Instant, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

getSelectors() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

getSelectors() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getServiceAccount() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getSessionJobConfig(FlinkDeployment, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

getSessionJobInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils

getSpecClass() - Method in class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentReconciliationStatus

getSpecClass() - Method in class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobReconciliationStatus

getSpecClass() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

getStateTimeHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

getStatistics() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

getSubstringWithMaxLength(String, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

getSupportedOptions() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet

getSupportedSourceVersion() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet

getTargetDirectory() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

getTargetDirectory() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

getTargetProcessingCapacity(Map<ScalingMetric, EvaluatedScalingMetric>, Configuration, double, boolean) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.utils.AutoScalerUtils

getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getTaskManagerCPU() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getTaskManagerDeploymentName(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

getTaskManagerMemoryMB() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getTaskManagerSelectors(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

getTaskManagersInfo(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

getTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext

getTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext

getTolerations() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

getTopologies() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

getTransitionHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

getUpgradeTargetGeneration(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Get spec generation for the current in progress upgrade.

getValueWithThreshold(Configuration, ConfigOption<T>, T) - Static method in class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils

Gets the value of ConfigOption with threshold.

getVerticesInTopologicalOrder() - Method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

gracePeriodEnded(Configuration, SavepointInfo) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

H

handle(AdmissionRequest) - Method in class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator

handleCanaryResourceDeletion(CR) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

handleCanaryResourceReconciliation(CR) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

hashCode() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

HealthProbe - Enum in org.apache.flink.kubernetes.operator.health

Flink operator health probe.

HISTO - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

hostname - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

HTTP_REQUEST_FAILED_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_REQUEST_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_1XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_2XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_3XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_4XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_5XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HTTP_RESPONSE_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

HttpArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact

Download the jar from the http resource.

HttpArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

HttpBootstrap - Class in org.apache.flink.kubernetes.operator.health

Class for serving HTTP requests for the health probe.

HttpBootstrap(HealthProbe, int) - Constructor for class org.apache.flink.kubernetes.operator.health.HttpBootstrap

I

IGNORE - org.apache.flink.kubernetes.operator.api.diff.DiffType

Ignorable spec change.

inc() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

inc(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

IneffectiveScaling - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

InformerHealthSummary - Class in org.apache.flink.kubernetes.operator.health

Operator informer health summary.

InformerHealthSummary() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerHealthSummary

InformerIdentifier - Class in org.apache.flink.kubernetes.operator.health

Operator informer identifier.

InformerIdentifier() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerIdentifier

InformerManager - Class in org.apache.flink.kubernetes.operator.admission.informer

The manager of the informers.

InformerManager(KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.admission.informer.InformerManager

ingressInNetworkingV1(KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils

IngressSpec - Class in org.apache.flink.kubernetes.operator.api.spec

Ingress spec.

IngressSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.IngressSpec

IngressUtils - Class in org.apache.flink.kubernetes.operator.utils

Ingress utilities.

IngressUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.IngressUtils

init(Locale, Reporter) - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet

initOperatorMetrics(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

initSpec() - Method in class org.apache.flink.kubernetes.operator.api.FlinkDeployment

initSpec() - Method in class org.apache.flink.kubernetes.operator.api.FlinkSessionJob

InitStandaloneTaskManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators

An initializer for the TaskManager FlinkPod in standalone mode.

InitStandaloneTaskManagerDecorator(StandaloneKubernetesTaskManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.InitStandaloneTaskManagerDecorator

initStatus() - Method in class org.apache.flink.kubernetes.operator.api.FlinkDeployment

initStatus() - Method in class org.apache.flink.kubernetes.operator.api.FlinkSessionJob

INNEFFECTIVE_MESSAGE_FORMAT - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler

INSTANCE - org.apache.flink.kubernetes.operator.health.HealthProbe

INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders

intercept(Interceptor.Chain) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

INTERNAL_METADATA_JSON_KEY - Static variable in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils

IOMetricsInfo - Class in org.apache.flink.runtime.rest.messages.job.metrics

IO metrics information.

IOMetricsInfo(long, boolean, long, boolean, long, boolean, long, boolean, Long, Long, Double) - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isApplicationCluster() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

isAvailable() - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode

isBeforeFirstDeployment() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

isBytesReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isBytesWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isCalculateAverage() - Method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

isCanaryResource(HasMetadata) - Static method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

isCancelJob() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

isClient() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

isHAEnabled() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

isHaMetadataAvailable(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

isHaMetadataAvailable(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

isHealthy() - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

isInternalServiceEnabled() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

isJmDeploymentReady(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

isJobInTerminalState(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

isJobManagerPortReady(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

isJobManagerPortReady(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

isJobRunning(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

isKubernetesHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

isKubernetesHaMetadataAvailable(Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

isLastReconciledSpecStable() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

isNewerVersionThan(FlinkVersion) - Method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

isPipelineClasspathDefined() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

isProcessingBacklog(JobTopology, SortedMap<Instant, CollectedMetrics>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator

isRecordsReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isRecordsWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo

isResourceReadyToBeObserved(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

Check whether the resource should be observed.

isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

isScaledUp() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingSummary

isSource(JobVertexID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

isSuspendedJob(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

isUpgradeModeChangedToLastStateAndHADisabledPreviously(AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

isValid(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

isZookeeperHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

isZookeeperHaMetadataAvailable(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

J

JAR_ARTIFACT_HTTP_HEADER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

jmPodNeverStarted(Context<?>) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

Check if the jobmanager pod has never successfully started.

Job - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

JOB_UPGRADE_IGNORE_PENDING_SAVEPOINT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

JobAutoScaler - Interface in org.apache.flink.kubernetes.operator.reconciler.deployment

Per-job Autoscaler instance.

JobAutoScalerFactory - Interface in org.apache.flink.kubernetes.operator.reconciler.deployment

Factory to construct a new autoscaler instance.

JobAutoscalerFactoryImpl - Class in org.apache.flink.kubernetes.operator.autoscaler

Factory for loading JobAutoScalerImpl included in this module.

JobAutoscalerFactoryImpl() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.JobAutoscalerFactoryImpl

JobAutoScalerImpl - Class in org.apache.flink.kubernetes.operator.autoscaler

Application and SessionJob autoscaler.

JobAutoScalerImpl(KubernetesClient, ScalingMetricCollector, ScalingMetricEvaluator, ScalingExecutor, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.JobAutoScalerImpl

JOBMANAGER_ENTRYPOINT_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator

JobManagerDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

JobManagerDeploymentStatus - Enum in org.apache.flink.kubernetes.operator.api.status

Status of the Flink JobManager Kubernetes deployment.

JobManagerSpec - Class in org.apache.flink.kubernetes.operator.api.spec

JobManager spec.

JobManagerSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.JobManagerSpec

JobSpec - Class in org.apache.flink.kubernetes.operator.api.spec

Flink job spec.

JobSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.JobSpec

JobState - Enum in org.apache.flink.kubernetes.operator.api.spec

Enum describing the desired job state.

JobStatus - Class in org.apache.flink.kubernetes.operator.api.status

Last observed status of the Flink job within an application deployment.

JobStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.JobStatus

JobStatusChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

JobStatusObserver<R extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.observer

An observer to observe the job status.

JobStatusObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

JobTopology - Class in org.apache.flink.kubernetes.operator.autoscaler.topology

Structure representing information about the jobgraph that is relevant for scaling.

JobTopology(Set<VertexInfo>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

JobTopology(VertexInfo...) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

JobVertexScaler - Class in org.apache.flink.kubernetes.operator.autoscaler

Component responsible for computing vertex parallelism based on the scaling metrics.

JobVertexScaler(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler

K

K8S_OP_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

KIND_FLINK_DEPLOYMENT - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants

KIND_SESSION_JOB - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants

KUBE_CLIENT_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

KUBERNETES_TASKMANAGER_REPLICAS - Static variable in class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal

kubernetesClient - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

kubernetesClient - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

KubernetesClientMetrics - Class in org.apache.flink.kubernetes.operator.metrics

Kubernetes client metrics.

KubernetesClientMetrics(MetricGroup, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

KubernetesClientUtils - Class in org.apache.flink.kubernetes.operator.utils

Kubernetes client utils.

KubernetesClientUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils

KubernetesDeploymentMode - Enum in org.apache.flink.kubernetes.operator.api.spec

Enum to control Flink deployment mode on Kubernetes.

KubernetesOperatorConfigOptions - Class in org.apache.flink.kubernetes.operator.config

This class holds configuration constants used by flink operator.

KubernetesOperatorConfigOptions() - Constructor for class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

KubernetesOperatorMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics

Base metric group for Flink Operator System metrics.

KubernetesOperatorMetricOptions - Class in org.apache.flink.kubernetes.operator.metrics

Configuration options for metrics.

KubernetesOperatorMetricOptions() - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

KubernetesOperatorScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics

Format for metrics.

KubernetesOperatorScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

KubernetesResourceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics

Base metric group for Flink Operator Resource level metrics.

KubernetesResourceMetricGroup(MetricRegistry, KubernetesResourceNamespaceMetricGroup, String[], String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

KubernetesResourceNamespaceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics

Base metric group for Flink Operator Resource namespace level metrics.

KubernetesResourceNamespaceMetricGroup(MetricRegistry, KubernetesOperatorMetricGroup, String[], String, String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

KubernetesResourceNamespaceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics

Format for metrics.

KubernetesResourceNamespaceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

KubernetesResourceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics

Format for metrics.

KubernetesResourceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

KubernetesStandaloneClusterDescriptor - Class in org.apache.flink.kubernetes.operator.standalone

Standalone Kubernetes specific ClusterDescriptor implementation.

KubernetesStandaloneClusterDescriptor(Configuration, FlinkStandaloneKubeClient) - Constructor for class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor

L

LABEL_TARGET_SESSION - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants

LABEL_TYPE_STANDALONE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

LAG - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Total number of pending records.

LAST_STATE - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode

Job is upgraded using any latest checkpoint or savepoint available.

LifecycleMetrics<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle

Utility for tracking resource lifecycle metrics globally and per namespace.

LifecycleMetrics(FlinkConfigManager, KubernetesOperatorMetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

LifecycleMetrics.Transition - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle

Pojo for encapsulating state transitions and whether we should measure time from the beginning of from or since the last update.

ListenerUtils - Class in org.apache.flink.kubernetes.operator.listener

Flink resource listener utilities.

ListenerUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.ListenerUtils

listJobs(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

listJobs(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

LOAD_AVG - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Average subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).

LOAD_MAX - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Max subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).

loadGlobalConfiguration(Optional<String>) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

loadJobAutoscalerFactory() - Static method in class org.apache.flink.kubernetes.operator.utils.AutoscalerLoader

loadListenerConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils

LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher

LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher

logContext(FlinkResourceListener.ResourceEventContext<R>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils

logContext(FlinkResourceListener.StatusUpdateContext<R, S>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils

logEnvironmentInfo(Logger, String, String[]) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils

Logs information about the environment, like code revision, current user, Java version, and JVM parameters.

logger - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

logger - Variable in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

M

main(String[]) - Static method in class autoscaling.AutoscalingExample

main(String[]) - Static method in class org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook

main(String[]) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker

main(String[]) - Static method in class org.apache.flink.kubernetes.operator.docs.configuration.ConfigOptionsDocGenerator

This method generates html tables from set of classes containing ConfigOptions.

main(String...) - Static method in class org.apache.flink.kubernetes.operator.FlinkOperator

MANUAL - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType

Savepoint manually triggered by changing the savepointTriggerNonce.

markEvent() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

markEvent(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

markReconciledSpecAsStable() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

max(DiffType, DiffType) - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType

MAX - org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator

MAX_CM_BYTES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

MAX_PARALLELISM - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Job vertex max parallelism.

MAX_SCALE_DOWN_FACTOR - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

MAX_SCALE_UP_FACTOR - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

measureFromLastUpdate - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

MEMORY_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

mergePodTemplates(Pod, Pod, boolean) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

METER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics

MetricAggregator - Enum in org.apache.flink.kubernetes.operator.autoscaler.metrics

Enum specifying which aggregator to use when getting a metric value.

MetricManager<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.metrics

Metric manager for Operator managed custom resources.

MetricManager() - Constructor for class org.apache.flink.kubernetes.operator.metrics.MetricManager

metricName - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

METRICS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

MIN - org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator

Missing - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

MISSING - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

JobManager deployment not found, probably not started or killed by user.

MISSING_SESSION_JOB_ERR - Static variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

MissingJobManagerException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal missing job manager.

MissingJobManagerException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException

MissingJobManagerException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException

MissingJobManagerException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException

MissingSessionJobException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal missing session job.

MissingSessionJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException

MissingSessionJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException

MissingSessionJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException

Mode - Enum in org.apache.flink.kubernetes.operator.config

The mode of FlinkDeployment.

monitorSizeOf(T, String) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

MSG_ROLLBACK - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

MSG_SPEC_CHANGED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

MSG_SUBMIT - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

MSG_SUSPENDED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

mutate(HasMetadata, Operation) - Method in class org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator

MUTATOR_REQUEST_PATH - Static variable in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler

N

name - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

namespace - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat

NATIVE - org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode

Deploys Flink using Flinks native Kubernetes support.

NATIVE - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType

A format specific for the chosen state backend.

NativeFlinkService - Class in org.apache.flink.kubernetes.operator.service

Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.

NativeFlinkService(KubernetesClient, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.service.NativeFlinkService

newEngine(ByteBufAllocator) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

newEngine(ByteBufAllocator, String, int) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

NoopJobAutoscalerFactory - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

An autoscaler implementation which does nothing.

NoopJobAutoscalerFactory() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory

Normal - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

NUM_RECORDS_IN_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

NUM_RECORDS_OUT_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

O

objectMapper - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

observe(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

observe(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.observer.Observer

Observe the flinkApp status, It will reflect the changed status on the flinkApp resource.

observe(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver

Observe the health of the flink cluster.

observe(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Observe the status of the flink job.

observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

Observe the flinkApp status when the cluster is ready.

observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver

observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver

observeInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

Internal observer logic specific to each resource type.

observeInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

observeInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

observeJmDeployment(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

Observer<CR extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.observer

The Observer of custom resource.

observeSavepointStatus(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.SavepointObserver

of(double) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.EvaluatedScalingMetric

of(String, long, SavepointTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint

of(String, SavepointTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint

of(String, SavepointTriggerType, SavepointFormatType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint

onDeploymentEvent(FlinkResourceListener.ResourceEventContext<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener

onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment, FlinkDeploymentStatus>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener

onFileOrDirectoryCreated(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

onFileOrDirectoryDeleted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

onFileOrDirectoryModified(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

onNoJobsFound(R, Configuration) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Callback when no jobs were found on the cluster.

onRemove(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics

onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

onRemove(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

onRemove(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

onSessionJobEvent(FlinkResourceListener.ResourceEventContext<FlinkSessionJob>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener

onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob, FlinkSessionJobStatus>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener

onTargetJobNotFound(R, Configuration) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Callback when no matching target job was found on a cluster where jobs were found.

onTimeout(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

Callback when list jobs timeout.

onUpdate(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics

onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

onUpdate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

onUpdate(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics

onUpdate(ResourceLifecycleState, Instant) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

onWatchStarted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

Operator - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CONFIG_CACHE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_CONFIG_CACHE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_DYNAMIC_CONFIG_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_DYNAMIC_CONFIG_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_DYNAMIC_NAMESPACES_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_FIELD_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_STACK_TRACE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_STACK_TRACE_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_EXCEPTION_THROWABLE_LIST_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_FLINK_CLIENT_CANCEL_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_FLINK_CLIENT_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_HEALTH_PROBE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_HEALTH_PROBE_PORT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JM_DEPLOYMENT_RECOVERY_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JM_SHUTDOWN_TTL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOB_RESTART_FAILED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOB_UPGRADE_LAST_STATE_CHECKPOINT_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOB_UPGRADE_LAST_STATE_FALLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_JOSDK_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_JVM_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_KUBERNETES_CLIENT_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_KUBERNETES_CLIENT_METRICS_HTTP_RESPONSE_CODE_GROUPS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_LABEL_SELECTOR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_LEASE_DURATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_LEASE_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_RENEW_DEADLINE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LEADER_ELECTION_RETRY_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_LIFECYCLE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_LIFECYCLE_NAMESPACE_HISTOGRAMS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_METRICS_HISTOGRAM_SAMPLE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_OBSERVER_PROGRESS_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_OBSERVER_REST_READY_DELAY - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RECONCILE_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RECONCILE_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RESOURCE_CLEANUP_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RESOURCE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

OPERATOR_RETRY_INITIAL_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RETRY_INTERVAL_MULTIPLIER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RETRY_MAX_ATTEMPTS - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_CLEANUP_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_FORMAT_TYPE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_AGE_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_SAVEPOINT_TRIGGER_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_STOP_ON_INFORMER_ERROR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_TERMINATION_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_USER_ARTIFACTS_BASE_DIR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_WATCHED_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

operatorConfig(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

operatorConfigKey(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OperatorHealthHandler - Class in org.apache.flink.kubernetes.operator.health

Simple code which returns HTTP 200 messages if the service is live, and HTTP 500 messages if the service is down.

OperatorHealthHandler() - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler

OperatorHealthService - Class in org.apache.flink.kubernetes.operator.health

Health probe service.

OperatorHealthService(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthService

OperatorJosdkMetrics - Class in org.apache.flink.kubernetes.operator.metrics

Implementation of Metrics to monitor and forward JOSDK metrics to MetricRegistry.

OperatorJosdkMetrics(KubernetesOperatorMetricGroup, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

OperatorMetricUtils - Class in org.apache.flink.kubernetes.operator.metrics

Utility class for flink based operator metrics.

OperatorMetricUtils() - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

OperatorMetricUtils.SynchronizedCounter - Class in org.apache.flink.kubernetes.operator.metrics

Thread safe Counter wrapper.

OperatorMetricUtils.SynchronizedHistogram - Class in org.apache.flink.kubernetes.operator.metrics

Thread safe Histogram wrapper.

OperatorMetricUtils.SynchronizedMeterView - Class in org.apache.flink.kubernetes.operator.metrics

Thread safe MeterView wrapper.

org.apache.flink.kubernetes.operator - package org.apache.flink.kubernetes.operator

org.apache.flink.kubernetes.operator.admission - package org.apache.flink.kubernetes.operator.admission

org.apache.flink.kubernetes.operator.admission.informer - package org.apache.flink.kubernetes.operator.admission.informer

org.apache.flink.kubernetes.operator.admission.mutator - package org.apache.flink.kubernetes.operator.admission.mutator

org.apache.flink.kubernetes.operator.api - package org.apache.flink.kubernetes.operator.api

org.apache.flink.kubernetes.operator.api.diff - package org.apache.flink.kubernetes.operator.api.diff

org.apache.flink.kubernetes.operator.api.docs - package org.apache.flink.kubernetes.operator.api.docs

org.apache.flink.kubernetes.operator.api.lifecycle - package org.apache.flink.kubernetes.operator.api.lifecycle

org.apache.flink.kubernetes.operator.api.listener - package org.apache.flink.kubernetes.operator.api.listener

org.apache.flink.kubernetes.operator.api.reconciler - package org.apache.flink.kubernetes.operator.api.reconciler

org.apache.flink.kubernetes.operator.api.spec - package org.apache.flink.kubernetes.operator.api.spec

org.apache.flink.kubernetes.operator.api.status - package org.apache.flink.kubernetes.operator.api.status

org.apache.flink.kubernetes.operator.api.utils - package org.apache.flink.kubernetes.operator.api.utils

org.apache.flink.kubernetes.operator.api.validation - package org.apache.flink.kubernetes.operator.api.validation

org.apache.flink.kubernetes.operator.artifact - package org.apache.flink.kubernetes.operator.artifact

org.apache.flink.kubernetes.operator.autoscaler - package org.apache.flink.kubernetes.operator.autoscaler

org.apache.flink.kubernetes.operator.autoscaler.config - package org.apache.flink.kubernetes.operator.autoscaler.config

org.apache.flink.kubernetes.operator.autoscaler.metrics - package org.apache.flink.kubernetes.operator.autoscaler.metrics

org.apache.flink.kubernetes.operator.autoscaler.topology - package org.apache.flink.kubernetes.operator.autoscaler.topology

org.apache.flink.kubernetes.operator.autoscaler.utils - package org.apache.flink.kubernetes.operator.autoscaler.utils

org.apache.flink.kubernetes.operator.config - package org.apache.flink.kubernetes.operator.config

org.apache.flink.kubernetes.operator.controller - package org.apache.flink.kubernetes.operator.controller

org.apache.flink.kubernetes.operator.docs.configuration - package org.apache.flink.kubernetes.operator.docs.configuration

org.apache.flink.kubernetes.operator.docs.util - package org.apache.flink.kubernetes.operator.docs.util

org.apache.flink.kubernetes.operator.exception - package org.apache.flink.kubernetes.operator.exception

org.apache.flink.kubernetes.operator.fs - package org.apache.flink.kubernetes.operator.fs

org.apache.flink.kubernetes.operator.health - package org.apache.flink.kubernetes.operator.health

org.apache.flink.kubernetes.operator.kubeclient - package org.apache.flink.kubernetes.operator.kubeclient

org.apache.flink.kubernetes.operator.kubeclient.decorators - package org.apache.flink.kubernetes.operator.kubeclient.decorators

org.apache.flink.kubernetes.operator.kubeclient.factory - package org.apache.flink.kubernetes.operator.kubeclient.factory

org.apache.flink.kubernetes.operator.kubeclient.parameters - package org.apache.flink.kubernetes.operator.kubeclient.parameters

org.apache.flink.kubernetes.operator.listener - package org.apache.flink.kubernetes.operator.listener

org.apache.flink.kubernetes.operator.metrics - package org.apache.flink.kubernetes.operator.metrics

org.apache.flink.kubernetes.operator.metrics.lifecycle - package org.apache.flink.kubernetes.operator.metrics.lifecycle

org.apache.flink.kubernetes.operator.observer - package org.apache.flink.kubernetes.operator.observer

org.apache.flink.kubernetes.operator.observer.deployment - package org.apache.flink.kubernetes.operator.observer.deployment

org.apache.flink.kubernetes.operator.observer.sessionjob - package org.apache.flink.kubernetes.operator.observer.sessionjob

org.apache.flink.kubernetes.operator.reconciler - package org.apache.flink.kubernetes.operator.reconciler

org.apache.flink.kubernetes.operator.reconciler.deployment - package org.apache.flink.kubernetes.operator.reconciler.deployment

org.apache.flink.kubernetes.operator.reconciler.diff - package org.apache.flink.kubernetes.operator.reconciler.diff

org.apache.flink.kubernetes.operator.reconciler.sessionjob - package org.apache.flink.kubernetes.operator.reconciler.sessionjob

org.apache.flink.kubernetes.operator.service - package org.apache.flink.kubernetes.operator.service

org.apache.flink.kubernetes.operator.ssl - package org.apache.flink.kubernetes.operator.ssl

org.apache.flink.kubernetes.operator.standalone - package org.apache.flink.kubernetes.operator.standalone

org.apache.flink.kubernetes.operator.utils - package org.apache.flink.kubernetes.operator.utils

org.apache.flink.kubernetes.operator.validation - package org.apache.flink.kubernetes.operator.validation

org.apache.flink.runtime.rest.messages.job.metrics - package org.apache.flink.runtime.rest.messages.job.metrics

org.apache.flink.runtime.rest.messages.job.savepoints - package org.apache.flink.runtime.rest.messages.job.savepoints

org.apache.flink.runtime.rest.messages.job.savepoints.stop - package org.apache.flink.runtime.rest.messages.job.savepoints.stop

P

PARALLELISM - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Job vertex parallelism.

PARALLELISM_OVERRIDES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

patchAndCacheStatus(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

Update the status of the provided kubernetes resource on the k8s cluster.

pending() - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

PENDING - org.apache.flink.kubernetes.operator.utils.SavepointStatus

Savepoint is pending, could be in the retry phase in the case of manual savepoint.

PENDING_RECORDS - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

PendingCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.PendingCheckpointInfo

PERIODIC - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType

Savepoint periodically triggered by the operator.

PERIODIC_SAVEPOINT_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

POD_IP_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator

POD_TEMPLATE_MERGE_BY_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

predicate - Variable in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

prefix() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry

prepareEventSources(EventSourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

prepareEventSources(EventSourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup

putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup

putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

Q

queryAggregatedMetricNames(RestClusterClient<?>, JobID, JobVertexID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

queryAggregatedVertexMetrics(FlinkService, AbstractFlinkResource<?, ?>, Configuration, JobVertexID, Map<String, FlinkMetric>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector

queryAllAggregatedMetrics(AbstractFlinkResource<?, ?>, FlinkService, Configuration, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector

queryAllAggregatedMetrics(AbstractFlinkResource<?, ?>, FlinkService, Configuration, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

queryFilteredMetricNames(FlinkService, AbstractFlinkResource<?, ?>, Configuration, JobTopology) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

Query the available metric names for each job vertex for the current spec generation.

queryJobTopology(RestClusterClient<String>, JobID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

R

READY - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

JobManager is running and ready to receive REST API calls.

readyToReconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Check whether the given Flink resource is ready to be reconciled or we are still waiting for any pending operation or condition first.

readyToReconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

readyToReconcile(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

readyToReconcile(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

REASON_CRASH_LOOP_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

REASON_ERR_IMAGE_PULL - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

REASON_IMAGE_PULL_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException

receivedEvent(Event, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

reconcile(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

reconcile(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

reconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

reconcile(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler

This is called when receiving the create or update event of the custom resource.

reconcileCustomResource(ResourceID, RetryInfo, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Reconcile any other changes required for this resource that are specific to the reconciler implementation.

reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

Reconciler<CR extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.reconciler

The interface of reconciler.

ReconcilerFactory - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

The factory to create reconciler based on app mode.

ReconcilerFactory(KubernetesClient, FlinkConfigManager, EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory

reconcileSpecChange(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Reconcile spec upgrade on the currently deployed/suspended Flink resource and update the status accordingly.

reconcileSpecChange(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

reconcileSpecChange(FlinkResourceContext<FlinkDeployment>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

ReconciliationException - Exception in org.apache.flink.kubernetes.operator.exception

Exception for wrapping reconciliation errors.

ReconciliationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException

ReconciliationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException

ReconciliationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException

ReconciliationMetadata - Class in org.apache.flink.kubernetes.operator.api.reconciler

Extra metadata to be attached to the reconciled spec.

ReconciliationMetadata() - Constructor for class org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata

ReconciliationState - Enum in org.apache.flink.kubernetes.operator.api.status

Current state of the reconciliation.

ReconciliationStatus<SPEC extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.status

Status of the last reconcile step for the FlinkDeployment/FlinkSessionJob.

ReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

ReconciliationUtils - Class in org.apache.flink.kubernetes.operator.reconciler

Reconciliation utilities.

ReconciliationUtils() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

RecoverDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

RecoveryFailureException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal non-terminal deployment failure.

RecoveryFailureException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException

ReflectiveDiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff

Assists in comparing Diffable objects with reflection.

ReflectiveDiffBuilder(T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder

register(CustomResourceMetrics<CR>) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

registerCanaryResourceManager(CanaryResourceManager<?>) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

registerScalingMetrics(Supplier<Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFlinkMetrics

reload() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

ReloadableSslContext - Class in org.apache.flink.kubernetes.operator.ssl

SSL context which is able to reload keystore.

ReloadableSslContext(String, String, String) - Constructor for class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

removeCachedStatus(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

Remove cached status for Flink resource.

removeLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

removeOperatorConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

replaceInKubernetes(KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

requestJobResult(Configuration, JobID) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

requestJobResult(Configuration, JobID) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

rescheduleAfter(JobManagerDeploymentStatus, FlinkDeployment, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

resetTrigger() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

resetTriggerIfJobNotRunning(AbstractFlinkResource<?, ?>, EventRecorder) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

Resource - Class in org.apache.flink.kubernetes.operator.api.spec

Resource spec.

Resource() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.Resource

RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat

RESOURCE_DELETION_PROPAGATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

RESOURCE_NS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

RESOURCE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat

RESOURCE_USAGE_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

ResourceLifecycleMetricTracker - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle

Lifecycle state transition tracker for a single resource.

ResourceLifecycleMetricTracker(ResourceLifecycleState, Instant, Map<String, List<Histogram>>, Map<ResourceLifecycleState, List<Histogram>>) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker

ResourceLifecycleState - Enum in org.apache.flink.kubernetes.operator.api.lifecycle

Enum encapsulating the lifecycle state of a Flink resource.

resourceMetricGroups - Variable in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

resourceScaler - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

RestApiMetricsCollector - Class in org.apache.flink.kubernetes.operator.autoscaler

Metric collector using flink rest api.

RestApiMetricsCollector() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector

RESTART_TIME - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

RestartUnhealthyJob - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

restoreJob(FlinkResourceContext<CR>, SPEC, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

resubmitJob(FlinkResourceContext<CR>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

rollback(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Rollback deployed resource to the last stable spec.

rollback(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

rollback(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

Rollback - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

ROLLED_BACK - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

ROLLED_BACK - org.apache.flink.kubernetes.operator.api.status.ReconciliationState

Rolled back to the lastStableSpec.

ROLLING_BACK - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

ROLLING_BACK - org.apache.flink.kubernetes.operator.api.status.ReconciliationState

In the process of rolling back to the lastStableSpec.

roundMetric(double) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics

run() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

run() - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService

run(DocletEnvironment) - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet

RUNNING - org.apache.flink.kubernetes.operator.api.spec.JobState

Job is expected to be processing data.

S

Savepoint - Class in org.apache.flink.kubernetes.operator.api.status

Represents information about a finished savepoint.

Savepoint(long, String, SavepointTriggerType, SavepointFormatType, Long) - Constructor for class org.apache.flink.kubernetes.operator.api.status.Savepoint

SAVEPOINT - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode

Job is upgraded by first taking a savepoint of the running job, shutting it down and restoring from the savepoint.

SavepointError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

SavepointFetchResult - Class in org.apache.flink.kubernetes.operator.observer

Result of a fetch savepoint operation.

SavepointFetchResult() - Constructor for class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult

SavepointFormatType - Enum in org.apache.flink.kubernetes.operator.api.status

Savepoint format type.

SavepointInfo - Class in org.apache.flink.kubernetes.operator.api.status

Stores savepoint related information.

SavepointInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

savepointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

SavepointObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.observer

An observer of savepoint progress.

SavepointObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.SavepointObserver

SavepointStatus - Enum in org.apache.flink.kubernetes.operator.utils

Enum encapsulating the lifecycle state of a Flink resource.

SavepointTriggerRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints

RequestBody to trigger savepoints.

SavepointTriggerRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody

SavepointTriggerType - Enum in org.apache.flink.kubernetes.operator.api.status

Savepoint trigger mechanism.

SavepointUtils - Class in org.apache.flink.kubernetes.operator.utils

Savepoint utilities.

SavepointUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.SavepointUtils

scale(int, int, double, int, int) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler

scale(ObjectMeta, JobSpec, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

scale(ObjectMeta, JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

scale(FlinkResourceContext) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory

scale(FlinkResourceContext<? extends AbstractFlinkResource<?, ?>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobAutoScalerImpl

scale(FlinkResourceContext<? extends AbstractFlinkResource<?, ?>>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.deployment.JobAutoScaler

Called as part of the reconciliation loop.

SCALE - org.apache.flink.kubernetes.operator.api.diff.DiffType

Scalable spec change.

SCALE_DOWN_RATE_THRESHOLD - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Lower boundary of the target data rate range.

SCALE_UP_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

SCALE_UP_RATE_THRESHOLD - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Upper boundary of the target data rate range.

scaleResource(AbstractFlinkResource<?, ?>, AutoScalerInfo, Configuration, Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

SCALING_EFFECTIVENESS_DETECTION_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

SCALING_EFFECTIVENESS_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

SCALING_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

SCALING_HISTORY_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

SCALING_SUMMARY_ENTRY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

SCALING_SUMMARY_HEADER_SCALING_DISABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

SCALING_SUMMARY_HEADER_SCALING_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

ScalingExecutor - Class in org.apache.flink.kubernetes.operator.autoscaler

Class responsible for executing scaling decisions.

ScalingExecutor(KubernetesClient, JobVertexScaler, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

ScalingExecutor(KubernetesClient, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

ScalingMetric - Enum in org.apache.flink.kubernetes.operator.autoscaler.metrics

Supported scaling metrics.

ScalingMetricCollector - Class in org.apache.flink.kubernetes.operator.autoscaler

Metric collector using flink rest api.

ScalingMetricCollector() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

ScalingMetricEvaluator - Class in org.apache.flink.kubernetes.operator.autoscaler

Job scaling evaluator for autoscaler.

ScalingMetricEvaluator() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator

ScalingMetrics - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics

Utilities for computing scaling metrics based on Flink metrics.

ScalingMetrics() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics

ScalingReport - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

ScalingSummary - Class in org.apache.flink.kubernetes.operator.autoscaler

Scaling summary returned by the ScalingMetricEvaluator.

ScalingSummary(int, int, Map<ScalingMetric, EvaluatedScalingMetric>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingSummary

SCOPE_NAMING_KUBERNETES_OPERATOR - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCENS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions

SECTION_ADVANCED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

SECTION_DYNAMIC - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

SECTION_SYSTEM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

sendResponse(ChannelHandlerContext, String) - Static method in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler

serialize(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo

serializeAndSetLastReconciledSpec(SPEC, AbstractFlinkResource<SPEC, ?>) - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus

SESSION - org.apache.flink.kubernetes.operator.config.Mode

SESSION - org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode

sessionClusterReady(Optional<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

sessionContext() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext

SessionJobReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.sessionjob

The reconciler for the FlinkSessionJob.

SessionJobReconciler(KubernetesClient, EventRecorder, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler

SessionObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment

The observer of the Mode.SESSION cluster.

SessionObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver

SessionReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment

Reconciler responsible for handling the session cluster lifecycle according to the desired and current states.

SessionReconciler(KubernetesClient, EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler

setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor

setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

setGenerationAnnotation(Configuration, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

setLastValidClusterHealthInfo(Map<String, String>, ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator

setNamespaces(Set<String>) - Method in class org.apache.flink.kubernetes.operator.admission.informer.InformerManager

setOwnerReference(CR, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

setRuntimeInfo(RuntimeInfo) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

setTrigger(String, SavepointTriggerType, SavepointFormatType) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

shouldDrain() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

shouldRecoverDeployment(Configuration, FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

Checks whether the JobManager Kubernetes Deployment recovery logic should be initiated.

shouldTriggerSavepoint(AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

Checks whether savepoint should be triggered based on the current status and spec and if yes, returns the correct SavepointTriggerType.

SOURCE_DATA_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Incoming data rate to the source, e.g.

SOURCE_TASK_NUM_RECORDS_IN_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

SpecChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

SpecDiff - Annotation Type in org.apache.flink.kubernetes.operator.api.diff

Spec diff annotation.

SpecDiff.Config - Annotation Type in org.apache.flink.kubernetes.operator.api.diff

Spec diff config annotation.

SpecDiff.Entry - Annotation Type in org.apache.flink.kubernetes.operator.api.diff

Spec diff config annotation entry.

SpecUtils - Class in org.apache.flink.kubernetes.operator.api.utils

Spec utilities.

SpecUtils() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.SpecUtils

SpecWithMeta<T extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.utils

Utility class for encapsulating Kubernetes resource spec and meta fields during serialization.

SpecWithMeta() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.SpecWithMeta

STABILIZATION_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

STABLE - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

STANDALONE - org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode

Deploys Flink on-top of kubernetes in standalone mode.

StandaloneFlinkService - Class in org.apache.flink.kubernetes.operator.service

Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.

StandaloneFlinkService(KubernetesClient, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

StandaloneKubernetesConfigOptionsInternal - Class in org.apache.flink.kubernetes.operator.standalone

This class holds internal configuration constants used by flink operator when deploying flink clusters in standalone mode.

StandaloneKubernetesConfigOptionsInternal() - Constructor for class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal

StandaloneKubernetesConfigOptionsInternal.ClusterMode - Enum in org.apache.flink.kubernetes.operator.standalone

The different modes that a Flink cluster can be deployed in.

StandaloneKubernetesJobManagerFactory - Class in org.apache.flink.kubernetes.operator.kubeclient.factory

Utility class for constructing all the Kubernetes for the JobManager deploying in standalone mode.

StandaloneKubernetesJobManagerFactory() - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory

StandaloneKubernetesJobManagerParameters - Class in org.apache.flink.kubernetes.operator.kubeclient.parameters

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.

StandaloneKubernetesJobManagerParameters(Configuration, ClusterSpecification) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters

StandaloneKubernetesTaskManagerFactory - Class in org.apache.flink.kubernetes.operator.kubeclient.factory

Utility class for constructing the TaskManager Deployment when deploying in standalone mode.

StandaloneKubernetesTaskManagerFactory() - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesTaskManagerFactory

StandaloneKubernetesTaskManagerParameters - Class in org.apache.flink.kubernetes.operator.kubeclient.parameters

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.

StandaloneKubernetesTaskManagerParameters(Configuration, ClusterSpecification) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters

StandaloneKubernetesUtils - Class in org.apache.flink.kubernetes.operator.utils

Standalone Kubernetes Utils.

StandaloneKubernetesUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils

start() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService

STATELESS - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode

Job is upgraded with empty state.

STATUS_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics

statusCache - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

StatusConflictException - Exception in org.apache.flink.kubernetes.operator.exception

Exception for status updates.

StatusConflictException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.StatusConflictException

statusRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

StatusRecorder<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.utils

Helper class for status management and updates.

StatusRecorder(KubernetesClient, MetricManager<CR>, BiConsumer<CR, STATUS>) - Constructor for class org.apache.flink.kubernetes.operator.utils.StatusRecorder

stop() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator

stop() - Method in class org.apache.flink.kubernetes.operator.health.HttpBootstrap

stop() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService

stopAndCleanupCluster(String) - Method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient

StopWithSavepointRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints.stop

RequestBody for stopping a job with a savepoint.

StopWithSavepointRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody

Submit - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

submitApplicationCluster(JobSpec, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

submitApplicationCluster(JobSpec, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

submitClusterInternal(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

submitClusterInternal(Configuration, Mode) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, Configuration, String) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

submitSessionCluster(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

SUCCEEDED - org.apache.flink.kubernetes.operator.utils.SavepointStatus

Savepoint is completed successfully.

Suspended - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

SUSPENDED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

SUSPENDED - org.apache.flink.kubernetes.operator.api.spec.JobState

Processing is suspended with the intention of continuing later.

synchronizedCounter(Counter) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

SynchronizedCounter(Counter) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter

SynchronizedHistogram(Histogram) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

synchronizedMeterView(MeterView) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils

SynchronizedMeterView(MeterView) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

T

TARGET_DATA_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Target processing rate of operators as derived from source inputs (records/sec).

TARGET_UTILIZATION - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

TARGET_UTILIZATION_BOUNDARY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

TASKMANAGER_ENTRYPOINT_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator

TaskManagerInfo - Class in org.apache.flink.kubernetes.operator.api.status

Last observed status of the Flink job within an application deployment.

TaskManagerInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.TaskManagerInfo

TaskManagerSpec - Class in org.apache.flink.kubernetes.operator.api.spec

TaskManager spec.

TaskManagerSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.TaskManagerSpec

testTriviallyEqual(boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder

timeControllerExecution(Metrics.ControllerExecution<T>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics

to - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

toErrorStatusUpdateControl(R, Optional<RetryInfo>, Exception, StatusRecorder<R, STATUS>, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Update the resource error status and metrics when the operator encountered an exception during reconciliation.

toString() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult

toUpdateControl(FlinkOperatorConfiguration, R, R, boolean) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

TRACKED_TRANSITIONS - Static variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics

Transition() - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, EventRecorder.Component, String) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerSavepoint(String, SavepointTriggerType, SavepointInfo, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

triggerSavepoint(String, SavepointTriggerType, SavepointInfo, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

triggerSavepointIfNeeded(FlinkService, AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils

Triggers any pending manual or periodic savepoints and updates the status accordingly.

trimHistoryToMaxCmSize() - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

TRUE_PROCESSING_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Processing rate at full capacity (records/sec).

type() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry

U

UNKNOWN - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType

Savepoint format unknown, if the savepoint was not triggered by the operator.

UNKNOWN - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType

Savepoint trigger mechanism unknown, such as savepoint retrieved directly from Flink job.

UnknownJobException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal unrecognized job found.

UnknownJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException

UnknownJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException

UnknownJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException

update() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

update(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram

updateDefaultConfig(Configuration) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager

updateErrorStatus(FlinkDeployment, Context<FlinkDeployment>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController

updateErrorStatus(FlinkSessionJob, Context<FlinkSessionJob>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController

updateFlinkResourceException(Throwable, R, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

updateForReconciliationError(AbstractFlinkResource<?, ?>, Throwable, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateIngressRules(ObjectMeta, FlinkDeploymentSpec, Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils

updateLastReconciledSavepointTriggerNonce(SavepointInfo, AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateLastSavepoint(Savepoint) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

Update last savepoint info and add the savepoint to the history if it isn't already the most recent savepoint.

updateMaxParallelism(JobVertexID, int) - Method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

updateMetricHistory(SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

updateMetrics(AbstractFlinkResource<?, ?>, AutoScalerInfo, FlinkService, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector

updateReconciliationMetadata(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateStatusAfterClusterDeletion(FlinkDeploymentStatus) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Update status before deployment attempt of a new resource spec.

updateStatusForAlreadyUpgraded(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Updates status in cases where a previously successful deployment wasn't recorded for any reason.

updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

Update status after successful deployment of a new resource spec.

updateStatusFromCache(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder

Update the custom resource status based on the in-memory cached to ensure that any status updates that we made previously are always visible in the reconciliation loop.

updateStatusToDeployedIfAlreadyUpgraded(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver

Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information.

updateStatusToDeployedIfAlreadyUpgraded(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

updateStatusToDeployedIfAlreadyUpgraded(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver

updateVertexList(List<JobVertexID>, Instant, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

UPGRADE - org.apache.flink.kubernetes.operator.api.diff.DiffType

Upgradable spec change.

UPGRADE - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType

Savepoint triggered during stateful upgrade.

UpgradeMode - Enum in org.apache.flink.kubernetes.operator.api.spec

Enum to control Flink job upgrade behavior.

UPGRADING - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

UPGRADING - org.apache.flink.kubernetes.operator.api.status.ReconciliationState

The spec is being upgraded.

URL - Static variable in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders

UserLibMountDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators

Mount the Flink User Lib directory to enable Flink to pick up a Jars defined in pipeline.classpaths.

UserLibMountDecorator(StandaloneKubernetesJobManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.UserLibMountDecorator

Utils - Class in org.apache.flink.kubernetes.operator.docs.util

Contains various shared utility functions.

Utils() - Constructor for class org.apache.flink.kubernetes.operator.docs.util.Utils

V

v1_13 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

v1_14 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

v1_15 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

v1_16 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

v1_17 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

validate(HasMetadata, Operation) - Method in class org.apache.flink.kubernetes.operator.admission.FlinkValidator

VALIDATE_REQUEST_PATH - Static variable in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler

validateDeployment(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator

validateDeployment(FlinkDeployment) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator

Validate and return optional error.

validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator

validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator

Validate and return optional error.

ValidationError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

ValidationException - Exception in org.apache.flink.kubernetes.operator.exception

Exception to signal validation failure.

ValidationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException

ValidationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException

ValidationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException

ValidatorUtils - Class in org.apache.flink.kubernetes.operator.utils

Validator utilities.

ValidatorUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ValidatorUtils

value() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Config

value() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.JobState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.UpgradeMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.ReconciliationState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointFormatType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.SavepointStatus

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.JobState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.UpgradeMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.ReconciliationState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointFormatType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.config.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.kubernetes.operator.utils.SavepointStatus

Returns an array containing the constants of this enum type, in the order they are declared.

verifyOtherPropsMatch(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker

VERTEX_EXCLUDE_IDS - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

VERTEX_MAX_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

VERTEX_MIN_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

VERTEX_SCALING_HISTORY_AGE - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

VERTEX_SCALING_HISTORY_COUNT - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions

VertexInfo - Class in org.apache.flink.kubernetes.operator.autoscaler.topology

Job vertex information.

VertexInfo() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.topology.VertexInfo

W

waitForClusterShutdown(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

waitForClusterShutdown(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

Warning - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

writeSpecWithMeta(AbstractFlinkSpec, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils

Serializes the spec and custom meta information into a JSON string.

writeSpecWithMeta(AbstractFlinkSpec, ReconciliationMetadata) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils

Serializes the spec and custom meta information into a JSON string.

Y

YAML_MAPPER - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo

A B C D E F G H I J K L M N O P Q R S T U V W Y
All Classes All Packages