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.SnapshotStatus

Manual snapshot is abandoned after defined retries.

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

Base observer for session and application clusters.

AbstractFlinkDeploymentObserver(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(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(EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - 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, ArtifactManager, ExecutorService, FlinkOperatorConfiguration) - 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(EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - 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.

addStartupProbe(Pod) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

addToScalingHistoryAndStore(AutoScalerStateStore<KEY, Context>, Context, Instant, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils

addToScalingHistoryAndStore(AutoScalerStateStore<KEY, Context>, Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>, Instant, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils

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.autoscaler.ScalingExecutor

ALREADY_SCALED - org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

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, 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

append(String, S, S, BiFunction<S, S, Boolean>, 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(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(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler

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

applyParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl

If there are any parallelism overrides by the JobAutoScaler apply them to the scalingRealizer.

applyPodTemplate() - 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

applyValidationErrorAndResetSpec(FlinkResourceContext<? extends AbstractFlinkResource<SPEC, ?>>, String) - 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

asJobResourceRequirements() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsBody

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 - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler

AUTOSCALER_CONF_PREFIX - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

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

AUTOSCALER_ERROR - Static variable in class org.apache.flink.autoscaler.JobAutoScalerImpl

AUTOSCALER_ERROR - Static variable in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor

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

AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.event

Handler for autoscaler events.

AutoScalerEventHandler.Type - Enum in org.apache.flink.autoscaler.event

The type of the events.

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

The factory of JobAutoScaler.

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

AutoscalerFlinkMetrics - Class in org.apache.flink.autoscaler.metrics

Autoscaler metrics for observability.

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

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

Config options related to the autoscaler module.

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

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

Jackson serializer module for JobVertexID.

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

AutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.state

The state store is responsible for storing all state during scaling.

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

AutoScaler utilities.

AutoScalerUtils() - Constructor for class org.apache.flink.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

AVERAGE - Static variable in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

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

B

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

BACKPRESSURE_TIME_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric

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

build() - Method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements.Builder

Builder() - Constructor for class org.apache.flink.runtime.jobgraph.JobResourceRequirements.Builder

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.autoscaler.config.AutoScalerOptions

BUSY_TIME_PER_SEC - org.apache.flink.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

CANNOT_SCALE - org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

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

A canonical, common for all state backends format.

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

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

CATCH_UP_DURATION - Static variable in class org.apache.flink.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, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

checkIfAlreadyUpgraded(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.

checkIfAlreadyUpgraded(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver

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

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

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

Represents information about a finished checkpoint.

Checkpoint(long, SnapshotTriggerType, CheckpointType, Long) - Constructor for class org.apache.flink.kubernetes.operator.api.status.Checkpoint

CHECKPOINT - org.apache.flink.kubernetes.operator.reconciler.SnapshotType

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

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

Result of a fetch checkpoint operation.

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

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.

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

Stores checkpoint-related information.

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

checkpointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

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

Checkpoint format type.

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(KEY) - Method in interface org.apache.flink.autoscaler.JobAutoScaler

Called when the job is deleted.

cleanup(KEY) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl

cleanup(KEY) - Method in class org.apache.flink.autoscaler.NoopJobAutoscaler

cleanup(KEY) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

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

clearAll(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

Removes all data from this context.

clearAll(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

clearAll(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

clearAll(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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.

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

close() - Method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor

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

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.state.KubernetesAutoScalerStateStore

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

Topology and collected metric history.

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

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

Collected scaling metrics.

CollectedMetrics() - Constructor for class org.apache.flink.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() - Static method in class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult

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, Supplier<Double>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics

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

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

computeObservedTprWithBackpressure(double, double) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics

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

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

computeScaleTargetParallelism(Context, JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>, SortedMap<Instant, ScalingSummary>) - Method in class org.apache.flink.autoscaler.JobVertexScaler

configManager - Variable in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext

ConfigMapStore - Class in org.apache.flink.kubernetes.operator.autoscaler.state

The ConfigMapStore persists state in Kubernetes ConfigMaps.

ConfigMapStore(KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

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) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFactory

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(Configuration, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager

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

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

createFlinkSessionJobMetricManager(Configuration, 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

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

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

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

createOrUpdateEventWithLabels(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String, Duration, Predicate<Map<String, String>>, Map<String, String>) - 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

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 - Static variable in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

CURRENT_PROCESSING_RATE - org.apache.flink.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

DEPRECATED_K8S_OP_CONF_PREFIX - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

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

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

E

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

Collected scaling metrics.

Edge() - Constructor for class org.apache.flink.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.jobgraph.JobResourceRequirements

equals(Object) - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements

equals(Object) - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism

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

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.CheckpointFetchResult

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.autoscaler.ScalingMetricEvaluator

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

Evaluated scaling metric.

EvaluatedScalingMetric(double, double) - Constructor for class org.apache.flink.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(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

excludeVertexFromScaling(Configuration, JobVertexID) - Static method in class org.apache.flink.autoscaler.utils.AutoScalerUtils

Temporarily exclude vertex from scaling for this run.

excludeVerticesFromScaling(Configuration, Collection<JobVertexID>) - Static method in class org.apache.flink.autoscaler.utils.AutoScalerUtils

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

EXPECTED_PROCESSING_RATE - org.apache.flink.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() - Method in class org.apache.flink.autoscaler.standalone.flinkcluster.FlinkClusterJobListFetcher

fetch() - Method in interface org.apache.flink.autoscaler.standalone.JobListFetcher

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

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

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

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.

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

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

findExistingEvent(KubernetesClient, HasMetadata, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils

FINISHED_METRICS - Static variable in enum org.apache.flink.autoscaler.metrics.FlinkMetric

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

FLINK_CLIENT_TIMEOUT - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

FLINK_CLUSTER_HOST - Static variable in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint

Arguments related to FlinkClusterJobListFetcher.

FLINK_CLUSTER_PORT - Static variable in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint

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

FlinkClusterJobListFetcher - Class in org.apache.flink.autoscaler.standalone.flinkcluster

Fetch JobAutoScalerContext based on flink cluster.

FlinkClusterJobListFetcher(FunctionWithException<Configuration, RestClusterClient<String>, Exception>, Duration) - Constructor for class org.apache.flink.autoscaler.standalone.flinkcluster.FlinkClusterJobListFetcher

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, FlinkConfigManager, Function<FlinkResourceContext<?>, FlinkService>) - 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(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(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.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

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(FlinkConfigManager, KubernetesOperatorMetricGroup, EventRecorder) - 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.

FlinkResourceUtils - Class in org.apache.flink.kubernetes.operator.api.utils

Utilities for Flink K8S resource.

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

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.

FlinkService.ScalingResult - Enum in org.apache.flink.kubernetes.operator.service

Result of an in-place scaling operation.

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, FlinkConfigManager, Function<FlinkResourceContext<?>, FlinkService>) - 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(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(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

flush(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

Flushing is needed because we do not persist data for all store methods until this method is called.

flush(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

flush(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

flush(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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

formatErrorMessage(Long) - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

formatErrorMessage(Long) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

formatErrorMessage(Long) - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

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

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>, Set<JobVertexID>) - Static method in class org.apache.flink.autoscaler.topology.JobTopology

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

FULL - org.apache.flink.kubernetes.operator.api.status.CheckpointType

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.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.autoscaler.ScalingMetricCollector

getAverage(ScalingMetric, JobVertexID, SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator

getAverage(ScalingMetric, JobVertexID, SortedMap<Instant, CollectedMetrics>, int) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator

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.autoscaler.state.ConfigMapStore

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

getCheckpointInfo(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

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

getCollectedMetrics(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

getCollectedMetrics(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

getCollectedMetrics(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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

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

Get the base configuration for the given namespace and flink version combination.

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

Get deployment configuration that will be passed to the Flink Cluster clients during cluster submission.

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

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() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext

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

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

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 enum org.apache.flink.kubernetes.operator.api.status.CheckpointType

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

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

getDescription() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getDescription() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

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(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory

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

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

getFlinkVersion() - 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.autoscaler.ScalingMetricCollector

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

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

getHttpMethod() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getHttpMethod() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

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

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

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

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

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

getJobDetailsInfo(JobAutoScalerContext<KEY>, Duration) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

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

getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec, ? extends CommonStatus<?>>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

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

getJobStatus(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

getJobTopology(Context, AutoScalerStateStore<KEY, Context>, JobDetailsInfo) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

getJobTopology(JobDetailsInfo) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

getJobUpdateTs(JobDetailsInfo) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

getJobVertexParallelisms() - Method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements

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

getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

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

Get KubernetesClient available from JOSDK Context.

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

getLastPeriodicTriggerTimestamp() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

getLastPeriodicTriggerTimestamp() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

getLastPeriodicTriggerTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

getLastSnapshot() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

getLastSnapshot() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

getLastSnapshot() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

getLastSnapshotStatus(AbstractFlinkResource<?, ?>, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

getLastTriggerNonce() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

getLastTriggerNonce() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

getLastTriggerNonce() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

getLastTriggerType() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

getLastTriggerType() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

getLastTriggerType() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

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

getLowerBound() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism

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

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

getMetricGroup() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

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.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

getNumBalancedCount() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

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

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

getNumErrorsCount() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

getNumScalingsCount() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

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

Get the observe configuration that can be used to interact with already submitted clusters through the Flink rest clients.

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

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

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

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

Get the operator configuration for the given namespace and flink version combination.

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

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

getParallelism() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements

getParallelism(JobVertexID) - Method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements

getParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl

getParallelismOverrides(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

getParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

getParallelismOverrides(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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

getReconciledJobSpec(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

getReconciledJobState(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

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

getRequestClass() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getRequestClass() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

Get the value provided by environments.

getResource() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

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

getResponseClass() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getResponseClass() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

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

getResponseStatusCode() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getResponseStatusCode() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

getRestClusterClient() - Method in class org.apache.flink.autoscaler.JobAutoScalerContext

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

getSavepointInfo(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils

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

getScalingHistory(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

getScalingHistory(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

getScalingHistory(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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

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

getSerializedState(KubernetesJobAutoScalerContext, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

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

Get configuration for interacting with session jobs.

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.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

getTargetRestEndpointURL() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getTargetRestEndpointURL() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

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

getTimeStamp() - Method in interface org.apache.flink.kubernetes.operator.api.status.Snapshot

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

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

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

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

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

getTriggerId() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

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

getTriggerTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

getTriggerType() - Method in interface org.apache.flink.kubernetes.operator.api.status.Snapshot

getTriggerType() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

getTrimmedScalingHistory(AutoScalerStateStore<KEY, Context>, Context, Instant) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils

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

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

getUnresolvedMessageParameters() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

getUnresolvedMessageParameters() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

Get spec generation for the current in progress upgrade.

getUpperBound() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism

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

Gets the value of ConfigOption with threshold.

getVertexResources(RestClusterClient<String>, AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

gracePeriodEnded(Duration, SnapshotInfo) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

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, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager

handleEvent(Context, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

Handle the event.

handleEvent(Context, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in class org.apache.flink.autoscaler.event.LoggingEventHandler

handleEvent(KubernetesJobAutoScalerContext, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

handleScalingEvent(Context, Map<JobVertexID, ScalingSummary>, boolean, Duration) - Method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

Handle scaling reports.

handleScalingEvent(KubernetesJobAutoScalerContext, Map<JobVertexID, ScalingSummary>, boolean, Duration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

hashCode() - Method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements

hashCode() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements

hashCode() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism

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

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

INCREMENTAL - org.apache.flink.kubernetes.operator.api.status.CheckpointType

incrementBalanced() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

incrementError() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

incrementScaling() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

INEFFECTIVE_MESSAGE_FORMAT - Static variable in class org.apache.flink.autoscaler.JobVertexScaler

INEFFECTIVE_SCALING - Static variable in class org.apache.flink.autoscaler.JobVertexScaler

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

initRecommendedParallelism(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Static method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

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

InMemoryAutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.state

State store based on the Java Heap, the state will be discarded after process restarts.

InMemoryAutoScalerStateStore() - Constructor for class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

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

INSTANCE - Static variable in class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

INSTANCE - Static variable in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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.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.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.autoscaler.ScalingSummary

isSnapshotTriggeringSupported(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

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

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

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

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

JOB_VERTEX_ID - Static variable in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

JobAutoScaler<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler

Flink Job AutoScaler.

JobAutoScalerContext<KEY> - Class in org.apache.flink.autoscaler

The job autoscaler context, it includes all details related to the current job.

JobAutoScalerContext() - Constructor for class org.apache.flink.autoscaler.JobAutoScalerContext

JobAutoScalerImpl<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler

The default implementation of JobAutoScaler.

JobAutoScalerImpl(ScalingMetricCollector<KEY, Context>, ScalingMetricEvaluator, ScalingExecutor<KEY, Context>, AutoScalerEventHandler<KEY, Context>, ScalingRealizer<KEY, Context>, AutoScalerStateStore<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.JobAutoScalerImpl

JobListFetcher<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.standalone

The JobListFetcher will fetch the jobContext of all jobs.

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

JobResourceRequirements - Class in org.apache.flink.runtime.jobgraph

Copied from Flink.

JobResourceRequirements(Map<JobVertexID, JobVertexResourceRequirements>) - Constructor for class org.apache.flink.runtime.jobgraph.JobResourceRequirements

JobResourceRequirements.Builder - Class in org.apache.flink.runtime.jobgraph

Builder.

JobResourceRequirementsBody - Class in org.apache.flink.runtime.rest.messages.job

Copied from Flink.

JobResourceRequirementsBody() - Constructor for class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsBody

JobResourceRequirementsBody(JobResourceRequirements) - Constructor for class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsBody

JobResourceRequirementsHeaders - Class in org.apache.flink.runtime.rest.messages.job

Copied from Flink.

JobResourceRequirementsHeaders() - Constructor for class org.apache.flink.runtime.rest.messages.job.JobResourceRequirementsHeaders

JobResourcesRequirementsUpdateHeaders - Class in org.apache.flink.runtime.rest.messages.job

Copied from Flink.

JobResourcesRequirementsUpdateHeaders() - Constructor for class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.JobStatusObserver

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

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

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

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

JobVertexResourceRequirements - Class in org.apache.flink.runtime.jobgraph

Copied from Flink.

JobVertexResourceRequirements(JobVertexResourceRequirements.Parallelism) - Constructor for class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements

JobVertexResourceRequirements.Parallelism - Class in org.apache.flink.runtime.jobgraph

Parallelisms.

JobVertexScaler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler

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

JobVertexScaler(AutoScalerEventHandler<KEY, Context>) - Constructor for class org.apache.flink.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

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

An event handler which posts events to the Kubernetes events API.

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

KubernetesAutoScalerStateStore - Class in org.apache.flink.kubernetes.operator.autoscaler.state

An AutoscalerStateStore which persists its state in Kubernetes ConfigMaps.

KubernetesAutoScalerStateStore(ConfigMapStore) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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.

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

An implementation of JobAutoscalerContext for Kubernetes.

KubernetesJobAutoScalerContext(JobID, JobStatus, Configuration, MetricGroup, SupplierWithException<RestClusterClient<String>, Exception>, AbstractFlinkResource<?, ?>, KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

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

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

The Kubernetes implementation for applying parallelism overrides.

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

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

LABELS - Static variable in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils

LAG - org.apache.flink.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(Configuration, 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 - org.apache.flink.autoscaler.metrics.ScalingMetric

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

loadListenerConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils

LoadSimulationPipeline - Class in autoscaling

Example pipeline which simulates fluctuating load from zero to a defined max, and vice-versa.

LoadSimulationPipeline() - Constructor for class autoscaling.LoadSimulationPipeline

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

LoggingEventHandler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.event

Autoscaler event handler which logs events.

LoggingEventHandler() - Constructor for class org.apache.flink.autoscaler.event.LoggingEventHandler

M

main(String[]) - Static method in class autoscaling.AutoscalingExample

main(String[]) - Static method in class autoscaling.LoadSimulationPipeline

main(String[]) - Static method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint

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.SnapshotTriggerType

Snapshot manually triggered by changing a triggerNonce.

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.autoscaler.metrics.MetricAggregator

MAX_CM_BYTES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

MAX_PARALLELISM - org.apache.flink.autoscaler.metrics.ScalingMetric

Job vertex max parallelism.

MAX_SCALE_DOWN_FACTOR - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

MAX_SCALE_UP_FACTOR - Static variable in class org.apache.flink.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.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

MetricNotFoundException - Exception in org.apache.flink.autoscaler.metrics

Exception for when an expected metric was not found.

MetricNotFoundException(FlinkMetric, JobVertexID) - Constructor for exception org.apache.flink.autoscaler.metrics.MetricNotFoundException

METRICS_WINDOW - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

MIN - org.apache.flink.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() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry

mode() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff

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

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

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, ArtifactManager, ExecutorService, FlinkOperatorConfiguration, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.service.NativeFlinkService

newBuilder() - Static method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements

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

NoopJobAutoscaler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler

An autoscaler implementation which does nothing.

NoopJobAutoscaler() - Constructor for class org.apache.flink.autoscaler.NoopJobAutoscaler

Normal - org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type

Normal - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type

NotReadyException - Exception in org.apache.flink.autoscaler.exceptions

An exception to indicate the called code wasn't ready but will be at a later point in time.

NotReadyException(Exception) - Constructor for exception org.apache.flink.autoscaler.exceptions.NotReadyException

NUM_RECORDS_IN_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric

NUM_RECORDS_OUT_PER_SEC - org.apache.flink.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.

OBSERVE_TRUE_PROCESSING_RATE_LAG_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

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

OBSERVED_TPR - org.apache.flink.autoscaler.metrics.ScalingMetric

Observed true processing rate for sources.

OBSERVED_TRUE_PROCESSING_RATE_MIN_OBSERVATIONS - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

OBSERVED_TRUE_PROCESSING_RATE_SWITCH_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

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.SnapshotObserver

of(double) - Static method in class org.apache.flink.autoscaler.metrics.EvaluatedScalingMetric

of(long, SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Checkpoint

of(String, long, SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint

of(String, SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint

of(String, SnapshotTriggerType, SavepointFormatType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint

of(SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Checkpoint

of(SnapshotTriggerType, CheckpointType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Checkpoint

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(FlinkResourceContext<R>) - 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(FlinkResourceContext<R>) - 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

operationId() - Method in class org.apache.flink.runtime.rest.messages.job.JobResourcesRequirementsUpdateHeaders

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

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

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

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_LABEL_MAPPER - 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_JM_STARTUP_PROBE_ENABLED - 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_RATE_LIMITER_LIMIT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

OPERATOR_RATE_LIMITER_PERIOD - 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_RETRY_MAX_INTERVAL - 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 - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

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.autoscaler - package org.apache.flink.autoscaler

org.apache.flink.autoscaler.config - package org.apache.flink.autoscaler.config

org.apache.flink.autoscaler.event - package org.apache.flink.autoscaler.event

org.apache.flink.autoscaler.exceptions - package org.apache.flink.autoscaler.exceptions

org.apache.flink.autoscaler.metrics - package org.apache.flink.autoscaler.metrics

org.apache.flink.autoscaler.realizer - package org.apache.flink.autoscaler.realizer

org.apache.flink.autoscaler.standalone - package org.apache.flink.autoscaler.standalone

org.apache.flink.autoscaler.standalone.flinkcluster - package org.apache.flink.autoscaler.standalone.flinkcluster

org.apache.flink.autoscaler.standalone.realizer - package org.apache.flink.autoscaler.standalone.realizer

org.apache.flink.autoscaler.state - package org.apache.flink.autoscaler.state

org.apache.flink.autoscaler.topology - package org.apache.flink.autoscaler.topology

org.apache.flink.autoscaler.utils - package org.apache.flink.autoscaler.utils

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.state - package org.apache.flink.kubernetes.operator.autoscaler.state

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.jobgraph - package org.apache.flink.runtime.jobgraph

org.apache.flink.runtime.rest.messages.job - package org.apache.flink.runtime.rest.messages.job

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(int, int) - Constructor for class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism

PARALLELISM - org.apache.flink.autoscaler.metrics.ScalingMetric

Job vertex parallelism.

PARALLELISM_MAP_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler

PARALLELISM_OVERRIDES_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

parseResourceMemoryString(String) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder

patchAndCacheStatus(CR, KubernetesClient) - 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.CheckpointFetchResult

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

PENDING - org.apache.flink.kubernetes.operator.utils.SnapshotStatus

Snapshot is pending, could be in the retry phase in the case of manual snapshots.

PENDING_RECORDS - org.apache.flink.autoscaler.metrics.FlinkMetric

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

PERIODIC - org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType

Snapshot periodically triggered by the operator.

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

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.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

putSerializedState(KubernetesJobAutoScalerContext, String, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

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.autoscaler.ScalingMetricCollector

queryAggregatedVertexMetrics(Context, JobVertexID, Map<String, FlinkMetric>) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector

queryAllAggregatedMetrics(Context, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector

queryAllAggregatedMetrics(Context, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

queryFilteredMetricNames(Context, JobTopology) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

Query the available metric names for each job vertex.

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

realize(Context, Map<String, String>) - Method in interface org.apache.flink.autoscaler.realizer.ScalingRealizer

Update job's parallelism to parallelismOverrides.

realize(Context, Map<String, String>) - Method in class org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer

realize(KubernetesJobAutoScalerContext, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer

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

RECOMMENDED_PARALLELISM - org.apache.flink.autoscaler.metrics.ScalingMetric

Recommended job vertex parallelism.

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(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory

reconcileSpecChange(FlinkResourceContext<CR>, Configuration, SPEC) - 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, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler

reconcileSpecChange(FlinkResourceContext<FlinkDeployment>, Configuration, FlinkDeploymentSpec) - 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(KubernetesDeploymentMode, 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(List<JobVertexID>, Supplier<Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>>) - Method in class org.apache.flink.autoscaler.metrics.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.

removeCollectedMetrics(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

removeCollectedMetrics(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

removeCollectedMetrics(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeInfoFromCache(ResourceID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

removeInfoFromCache(ResourceID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeInfoFromCache(KEY) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

Clean up all information related to the current job.

removeInfoFromCache(KEY) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

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

removeParallelismOverrides(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

removeParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

removeParallelismOverrides(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeScalingHistory(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

removeScalingHistory(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

removeScalingHistory(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

removeSerializedState(KubernetesJobAutoScalerContext, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore

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

RescaleApiScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.standalone.realizer

A ScalingRealizer which uses the Rescale API to apply parallelism changes.

RescaleApiScalingRealizer(AutoScalerEventHandler<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer

rescheduleAfter(JobManagerDeploymentStatus, FlinkDeployment, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

resetRecommendedParallelism(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Static method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics

resetSnapshotTriggers(AbstractFlinkResource<?, ?>, EventRecorder, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

resetTrigger() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

resetTrigger() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo

resetTrigger() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

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

REST_CLIENT_TIMEOUT - Static variable in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint

RestApiMetricsCollector<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler

Metric collector using flink rest api.

RestApiMetricsCollector() - Constructor for class org.apache.flink.autoscaler.RestApiMetricsCollector

RESTART_TIME - Static variable in class org.apache.flink.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 - 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.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

runJar(JobSpec, JobID, JarUploadResponseBody, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

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, SnapshotTriggerType, 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.

SAVEPOINT - org.apache.flink.kubernetes.operator.reconciler.SnapshotType

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

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.SnapshotUtils

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

scale(int, int, double, int, int) - Static method in class org.apache.flink.autoscaler.JobVertexScaler

scale(Context) - Method in interface org.apache.flink.autoscaler.JobAutoScaler

Compute and apply new parallelism overrides for the provided job context.

scale(Context) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl

scale(Context) - Method in class org.apache.flink.autoscaler.NoopJobAutoscaler

scale(FlinkResourceContext<?>, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

scale(FlinkResourceContext<?>, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

scale(FlinkResourceContext<?>, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

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

Scalable spec change.

SCALE_DOWN_RATE_THRESHOLD - org.apache.flink.autoscaler.metrics.ScalingMetric

Lower boundary of the target data rate range.

SCALE_UP_GRACE_PERIOD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

SCALE_UP_RATE_THRESHOLD - org.apache.flink.autoscaler.metrics.ScalingMetric

Upper boundary of the target data rate range.

scaleResource(Context, Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Method in class org.apache.flink.autoscaler.ScalingExecutor

scaling() - Method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor

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

SCALING_EFFECTIVENESS_DETECTION_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

SCALING_EFFECTIVENESS_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

SCALING_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

SCALING_EVENT_INTERVAL - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

SCALING_HISTORY_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

SCALING_INTERVAL - Static variable in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint

SCALING_REPORT_KEY - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

SCALING_REPORT_REASON - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

SCALING_SUMMARY_ENTRY - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

SCALING_SUMMARY_HEADER_SCALING_DISABLED - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

SCALING_SUMMARY_HEADER_SCALING_ENABLED - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

SCALING_TRIGGERED - org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

scalingCompleted(FlinkResourceContext<?>) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService

scalingCompleted(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

scalingCompleted(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService

ScalingExecutor<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler

Class responsible for executing scaling decisions.

ScalingExecutor(AutoScalerEventHandler<KEY, Context>, AutoScalerStateStore<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.ScalingExecutor

ScalingExecutor(JobVertexScaler<KEY, Context>, AutoScalerEventHandler<KEY, Context>, AutoScalerStateStore<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.ScalingExecutor

ScalingHistoryUtils - Class in org.apache.flink.autoscaler.metrics

The utils for scaling history.

ScalingHistoryUtils() - Constructor for class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils

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

ScalingMetric - Enum in org.apache.flink.autoscaler.metrics

Supported scaling metrics.

ScalingMetricCollector<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler

Metric collector using flink rest api.

ScalingMetricCollector() - Constructor for class org.apache.flink.autoscaler.ScalingMetricCollector

ScalingMetricEvaluator - Class in org.apache.flink.autoscaler

Job scaling evaluator for autoscaler.

ScalingMetricEvaluator() - Constructor for class org.apache.flink.autoscaler.ScalingMetricEvaluator

ScalingMetrics - Class in org.apache.flink.autoscaler.metrics

Utilities for computing scaling metrics based on Flink metrics.

ScalingMetrics() - Constructor for class org.apache.flink.autoscaler.metrics.ScalingMetrics

ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.realizer

The Scaling Realizer is responsible for applying scaling actions, i.e.

scalingReport(Map<JobVertexID, ScalingSummary>, boolean) - Static method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

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

ScalingSummary - Class in org.apache.flink.autoscaler

Scaling summary returned by the ScalingMetricEvaluator.

ScalingSummary(int, int, Map<ScalingMetric, EvaluatedScalingMetric>) - Constructor for class org.apache.flink.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

serializeEvaluatedMetrics(SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

serializeScalingHistory(Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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(EventRecorder, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>) - 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(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(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler

setClock(Clock) - Method in class org.apache.flink.autoscaler.JobVertexScaler

setClock(Clock) - Method in class org.apache.flink.autoscaler.ScalingExecutor

setClock(Clock) - Method in class org.apache.flink.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

setParallelismForJobVertex(JobVertexID, int, int) - Method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements.Builder

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

setTrigger(String, SnapshotTriggerType, CheckpointType) - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

setTrigger(String, SnapshotTriggerType, 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.

shouldTriggerSnapshot(AbstractFlinkResource<?, ?>, Configuration, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

Checks whether a snapshot should be triggered based on the current status and spec, and if yes, returns the correct SnapshotTriggerType.

Snapshot - Interface in org.apache.flink.kubernetes.operator.api.status

A common interface for Checkpoint and Savepoint.

SnapshotInfo - Interface in org.apache.flink.kubernetes.operator.api.status

Interface representing common snapshot information.

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

An observer of savepoint progress.

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

SnapshotStatus - Enum in org.apache.flink.kubernetes.operator.utils

Enum encapsulating the lifecycle state of a Flink snapshot.

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

Snapshot trigger mechanism.

SnapshotType - Enum in org.apache.flink.kubernetes.operator.reconciler

This enumeration represents the types of state snapshots that can be taken in Flink.

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

Savepoint utilities.

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

SOURCE_DATA_RATE - org.apache.flink.autoscaler.metrics.ScalingMetric

Incoming data rate to the source, e.g.

SOURCE_TASK_NUM_RECORDS_IN_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric

SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC - org.apache.flink.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.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.

StandaloneAutoscalerEntrypoint - Class in org.apache.flink.autoscaler.standalone

The entrypoint of the standalone autoscaler.

StandaloneAutoscalerEntrypoint() - Constructor for class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint

StandaloneAutoscalerExecutor<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.standalone

The executor of the standalone autoscaler.

StandaloneAutoscalerExecutor(Duration, JobListFetcher<KEY, Context>, AutoScalerEventHandler<KEY, Context>, JobAutoScaler<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor

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

Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.

StandaloneFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration) - 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.autoscaler.standalone.StandaloneAutoscalerExecutor

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(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

storeCollectedMetrics(Context, SortedMap<Instant, CollectedMetrics>) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

storeCollectedMetrics(Context, SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

storeCollectedMetrics(KubernetesJobAutoScalerContext, SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

storeParallelismOverrides(Context, Map<String, String>) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

storeParallelismOverrides(Context, Map<String, String>) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

storeParallelismOverrides(KubernetesJobAutoScalerContext, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

storeScalingHistory(Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore

storeScalingHistory(Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore

storeScalingHistory(KubernetesJobAutoScalerContext, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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.SnapshotStatus

Snapshot 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.autoscaler.metrics.ScalingMetric

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

TARGET_UTILIZATION - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

TARGET_UTILIZATION_BOUNDARY - Static variable in class org.apache.flink.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

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(FlinkResourceContext<R>, Exception, StatusRecorder<R, STATUS>) - 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

toString() - Method in class org.apache.flink.runtime.jobgraph.JobResourceRequirements

toString() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements.Parallelism

toString() - Method in class org.apache.flink.runtime.jobgraph.JobVertexResourceRequirements

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

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

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

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventOnce(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventOnce(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventWithInterval(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient, Duration) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

triggerEventWithLabels(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient, Duration, Predicate<Map<String, String>>, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder

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

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

triggerSnapshotIfNeeded(FlinkService, AbstractFlinkResource<?, ?>, Configuration, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

Triggers any pending manual or periodic snapshots and updates the status accordingly.

trimHistoryToMaxCmSize(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

trimScalingHistory(Instant, Configuration, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils

TRUE_PROCESSING_RATE - org.apache.flink.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.CheckpointType

Checkpoint format unknown, if the checkpoint was not triggered by the operator.

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.SnapshotTriggerType

Snapshot 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

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

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

updateAfterScaleUp(AbstractFlinkResource<SPEC, ?>, Configuration, Clock, FlinkService.ScalingResult) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils

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

Update the base configuration for the operator.

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(FlinkResourceContext, Throwable) - 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

updateLastCheckpoint(Checkpoint) - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo

Update last checkpoint info.

updateLastReconciledSnapshotTriggerNonce(SnapshotInfo, AbstractFlinkResource<SPEC, ?>, SnapshotType) - 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.autoscaler.topology.JobTopology

updateMetrics(Context, AutoScalerStateStore<KEY, Context>) - Method in class org.apache.flink.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<?, ?>) - 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.

updateVertexList(AutoScalerStateStore<KEY, Context>, Context, Instant, Set<JobVertexID>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils

updateVertexResources(RestClusterClient<String>, AbstractFlinkResource<?, ?>, Map<JobVertexID, JobVertexResourceRequirements>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService

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

Upgradable spec change.

UPGRADE - org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType

Snapshot 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.

uploadJar(ObjectMeta, FlinkSessionJobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService

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

v1_18 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion

v1_19 - 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

validateAutoScalerFlinkConfiguration(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator

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.

validateSupportedVersion(FlinkResourceContext<?>, EventRecorder) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils

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.autoscaler.event.AutoScalerEventHandler.Type

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.autoscaler.metrics.FlinkMetric

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.autoscaler.metrics.MetricAggregator

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.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.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.CheckpointType

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.SnapshotTriggerType

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.reconciler.SnapshotType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.service.FlinkService.ScalingResult

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.SnapshotStatus

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.autoscaler.event.AutoScalerEventHandler.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.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.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.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.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.CheckpointType

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.SnapshotTriggerType

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.reconciler.SnapshotType

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.service.FlinkService.ScalingResult

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.SnapshotStatus

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

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

VERTEX_EXCLUDE_IDS - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

VERTEX_MAX_PARALLELISM - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

VERTEX_MIN_PARALLELISM - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

VERTEX_SCALING_HISTORY_AGE - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

VERTEX_SCALING_HISTORY_COUNT - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions

VertexInfo - Class in org.apache.flink.autoscaler.topology

Job vertex information.

VertexInfo(JobVertexID, Set<JobVertexID>, int, int) - Constructor for class org.apache.flink.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.autoscaler.event.AutoScalerEventHandler.Type

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.state.KubernetesAutoScalerStateStore

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