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

A

ABANDONED - org.apache.flink.kubernetes.operator.utils.SavepointStatus
Manual savepoint is abandoned after defined retries.
AbstractFlinkDeploymentObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment
Base observer for session and application clusters.
AbstractFlinkDeploymentObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
AbstractFlinkResource<SPEC extends AbstractFlinkSpec,​STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.api
Abstract base class Flink resources.
AbstractFlinkResource() - Constructor for class org.apache.flink.kubernetes.operator.api.AbstractFlinkResource
 
AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,​?>> - Class in org.apache.flink.kubernetes.operator.observer
Base observer for all Flink resources.
AbstractFlinkResourceObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
 
AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,​STATUS>,​SPEC extends AbstractFlinkSpec,​STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
Base class for all Flink resource reconcilers.
AbstractFlinkResourceReconciler(KubernetesClient, EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
AbstractFlinkService - Class in org.apache.flink.kubernetes.operator.service
An abstract FlinkService containing some common implementations for the native and standalone Flink Services.
AbstractFlinkService(KubernetesClient, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
AbstractFlinkSpec - Class in org.apache.flink.kubernetes.operator.api.spec
The common spec.
AbstractFlinkSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec
 
AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,​STATUS>,​SPEC extends AbstractFlinkSpec,​STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
Reconciler responsible for handling the job lifecycle according to the desired and current states.
AbstractJobReconciler(KubernetesClient, EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
AbstractJobReconciler.AvailableUpgradeMode - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
Object to capture available upgrade mode.
addToScalingHistory(Instant, Map<JobVertexID, ScalingSummary>, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
AdmissionHandler - Class in org.apache.flink.kubernetes.operator.admission
Rest endpoint for validation requests.
AdmissionHandler(Validator<HasMetadata>, Mutator<HasMetadata>) - Constructor for class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
 
admissionResponseFromMutation(KubernetesResource, KubernetesResource) - Static method in class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator
 
allCanariesHealthy() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
allVerticesWithinUtilizationTarget(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
API_GROUP - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
 
API_VERSION - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
 
append(String, boolean[], boolean[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, boolean, boolean, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, byte[], byte[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, byte, byte, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, char[], char[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, char, char, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, double[], double[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, double, double, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, float[], float[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, float, float, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, int[], int[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, int, int, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, long[], long[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, long, long, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, short[], short[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, short, short, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, DiffResult<?>) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, Object[], Object[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
append(String, Object, Object, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
APPLICATION - org.apache.flink.kubernetes.operator.config.Mode
 
APPLICATION - org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
 
APPLICATION_MODE_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
 
ApplicationObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment
The observer of Mode.APPLICATION cluster.
ApplicationObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver
 
applicationProtocolNegotiator() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
ApplicationReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
Reconciler Flink Application deployments.
ApplicationReconciler(KubernetesClient, EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
applyCommonPodTemplate() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyFlinkConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyImage() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyImagePullPolicy() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyIngressDomain() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyJobManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyJobOrSessionSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyLogConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyResourceToPodTemplate(Pod, Resource) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyServiceAccount() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyTaskManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
applyToStoredCr(KubernetesClient, T, Consumer<T>) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
 
applyValidationErrorAndResetSpec(AbstractFlinkResource<SPEC, ?>, String, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking.
ArtifactFetcher - Interface in org.apache.flink.kubernetes.operator.artifact
The artifact fetcher.
artifactManager - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
ArtifactManager - Class in org.apache.flink.kubernetes.operator.artifact
Manage the user artifacts.
ArtifactManager(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.artifact.ArtifactManager
 
AuditUtils - Class in org.apache.flink.kubernetes.operator.listener
Responsible for logging resource event/status updates.
AuditUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.AuditUtils
 
AUTOSCALER_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
AutoscalerError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
AutoscalerFlinkMetrics - Class in org.apache.flink.kubernetes.operator.autoscaler
Autoscaler metrics for observability.
AutoscalerFlinkMetrics(MetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFlinkMetrics
 
AutoScalerInfo - Class in org.apache.flink.kubernetes.operator.autoscaler
Class for encapsulating information stored for each resource when using the autoscaler.
AutoScalerInfo(ConfigMap) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
AutoScalerInfo(Map<String, String>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
AutoscalerLoader - Class in org.apache.flink.kubernetes.operator.utils
Loads the active Autoscaler implementation from the classpath.
AutoscalerLoader() - Constructor for class org.apache.flink.kubernetes.operator.utils.AutoscalerLoader
 
AutoScalerOptions - Class in org.apache.flink.kubernetes.operator.autoscaler.config
Config options related to the autoscaler module.
AutoScalerOptions() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
AutoScalerSerDeModule - Class in org.apache.flink.kubernetes.operator.autoscaler.utils
Jackson serializer module for JobVertexID.
AutoScalerSerDeModule() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.utils.AutoScalerSerDeModule
 
AutoScalerUtils - Class in org.apache.flink.kubernetes.operator.autoscaler.utils
AutoScaler utilities.
AutoScalerUtils() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.utils.AutoScalerUtils
 
autoscaling - package autoscaling
 
AutoscalingExample - Class in autoscaling
Autoscaling Example.
AutoscalingExample() - Constructor for class autoscaling.AutoscalingExample
 
AvailableUpgradeMode() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode
 
AVG - org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator
 

B

BACKLOG_PROCESSING_LAG_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
build() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
build() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
build() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder
 
buildFrom(String, String, FlinkDeploymentSpec, Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
buildKubernetesJobManagerSpecification(FlinkPod, StandaloneKubernetesJobManagerParameters) - Static method in class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory
 
buildKubernetesTaskManagerDeployment(FlinkPod, StandaloneKubernetesTaskManagerParameters) - Static method in class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesTaskManagerFactory
 
BUSY_TIME_AGGREGATOR - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
BUSY_TIME_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 

C

calculateClusterCpuUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
calculateClusterMemoryUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
CANARY_LABEL - Static variable in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
CANARY_RESOURCE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
CanaryResourceManager<CR extends AbstractFlinkResource<?,​?>> - Class in org.apache.flink.kubernetes.operator.health
Logic encapsulating canary tests.
CanaryResourceManager() - Constructor for class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
cancelJob(FlinkDeployment, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
cancelJob(FlinkDeployment, UpgradeMode, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
cancelJob(FlinkResourceContext<CR>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
Cancel the job for the given resource using the specified upgrade mode.
cancelJob(FlinkResourceContext<FlinkDeployment>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
cancelJob(FlinkResourceContext<FlinkSessionJob>, UpgradeMode) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
cancelSessionJob(FlinkSessionJob, UpgradeMode, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
cancelSessionJob(FlinkSessionJob, UpgradeMode, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
CANONICAL - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType
A canonical, common for all state backends format.
CATCH_UP_DATA_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Target processing rate of operators as derived from backlog (records/sec).
CATCH_UP_DURATION - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
changeLastStateIfCheckpointTooOld(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler
 
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
 
checkAndUpdateStableSpec(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Checks the status and if the corresponding Flink job/application is in stable running state, it updates the last stable spec.
checkHealth(ResourceID) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
checkObjectCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
 
CheckpointHistoryWrapper - Class in org.apache.flink.kubernetes.operator.service
Custom Response for handling checkpoint history in a multi-version compatible way.
CheckpointHistoryWrapper() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper
 
CheckpointHistoryWrapper.CompletedCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service
Information about the latest completed checkpoint/savepoint.
CheckpointHistoryWrapper.PendingCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service
Information about the currently pending checkpoint/savepoint.
checkStringTypeCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
 
checkTypeCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
 
cipherSuites() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
cleanup(CR) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
 
cleanup(AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobAutoScalerImpl
 
cleanup(AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
cleanup(AbstractFlinkResource<?, ?>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.deployment.JobAutoScaler
Called when the custom resource is deleted.
cleanup(AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory
 
cleanup(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
 
cleanup(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
 
cleanup(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
cleanup(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler
This is called when receiving the delete event of custom resource.
Cleanup - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
cleanupAfterFailedJob(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
Removes a failed job.
cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
cleanupAfterFailedJob(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
cleanupDoneFor(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
CleanupFailed - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
cleanupInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Shut down and clean up all Flink job/cluster resources.
cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
cleanupInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
cleanupTmpFiles(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
clearErrorsIfDeploymentIsHealthy(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
clearLastReconciledSpecIfFirstDeploy(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Clear last reconciled spec if that corresponds to the first deployment.
clearMetricHistory() - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
clock - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
clone(T) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
 
clone(T) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
CLUSTER_MODE - Static variable in class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
 
ClusterHealthEvaluator - Class in org.apache.flink.kubernetes.operator.observer
Evaluates whether the cluster is healthy.
ClusterHealthEvaluator(Clock) - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
 
ClusterHealthInfo - Class in org.apache.flink.kubernetes.operator.health
Represents information about job health.
ClusterHealthInfo() - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
 
ClusterHealthInfo(Clock) - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
 
ClusterHealthObserver - Class in org.apache.flink.kubernetes.operator.observer
An observer to observe the cluster health.
ClusterHealthObserver() - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver
 
clusterShutdownDisabled(FlinkDeploymentSpec) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
CmdStandaloneJobManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators
Attach the command and args to the main container for running the JobManager in standalone mode.
CmdStandaloneJobManagerDecorator(StandaloneKubernetesJobManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
 
CmdStandaloneTaskManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators
Attach the command and args to the main container for running the TaskManager in standalone mode.
CmdStandaloneTaskManagerDecorator(StandaloneKubernetesTaskManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator
 
COLLECTED_METRICS_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
CollectedMetricHistory - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics
Topology and collected metric history.
CollectedMetricHistory() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.CollectedMetricHistory
 
CollectedMetrics - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics
Collected scaling metrics.
CollectedMetrics() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.CollectedMetrics
 
CommonStatus<SPEC extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.status
Last observed common status of the Flink deployment/Flink SessionJob.
CommonStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.CommonStatus
 
CompatibilityError(String) - Constructor for exception org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.CompatibilityError
 
completed(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
 
CompletedCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.CompletedCheckpointInfo
 
computeDataRateMetrics(JobVertexID, Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>, JobTopology, double, Configuration) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics
 
computeLagMetrics(Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics
 
computeLoadMetrics(Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics
 
computeOutputRatios(Map<JobVertexID, Map<FlinkMetric, AggregatedMetric>>, JobTopology) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics
 
computeProcessingRateThresholds(Map<ScalingMetric, EvaluatedScalingMetric>, Configuration, boolean) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator
 
computeScaleTargetParallelism(AbstractFlinkResource<?, ?>, Configuration, JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>, SortedMap<Instant, ScalingSummary>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler
 
configManager - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
 
configManager - Variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
 
configManager - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
ConfigOptionsDocGenerator - Class in org.apache.flink.kubernetes.operator.docs.configuration
Class used for generating code based documentation of configuration parameters.
ConfigOptionUtils - Class in org.apache.flink.kubernetes.operator.utils
ConfigOption utilities.
ConfigOptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils
 
COUNTER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
COUNTER_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
COUNTER_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
 
CPU_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
CR_GENERATION_LABEL - Static variable in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
CrdCompatibilityChecker - Class in org.apache.flink.kubernetes.operator.api.validation
Utility for checking backward CRD compatibility.
CrdCompatibilityChecker() - Constructor for class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
 
CrdCompatibilityChecker.CompatibilityError - Exception in org.apache.flink.kubernetes.operator.api.validation
Compatibility Error class.
CrdConstants - Class in org.apache.flink.kubernetes.operator.api
Constants used by the CRD.
CrdConstants() - Constructor for class org.apache.flink.kubernetes.operator.api.CrdConstants
 
CrdReferenceDoclet - Class in org.apache.flink.kubernetes.operator.api.docs
Doclet for generating the FlinkDeployment CRD reference.
CrdReferenceDoclet() - Constructor for class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
 
create(KubernetesClient, Collection<FlinkResourceListener>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
 
create(KubernetesClient, MetricManager<CR>, Collection<FlinkResourceListener>) - Static method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
 
create(KubernetesClient, EventRecorder) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobAutoscalerFactoryImpl
 
create(KubernetesClient, EventRecorder) - Method in interface org.apache.flink.kubernetes.operator.reconciler.deployment.JobAutoScalerFactory
 
create(KubernetesClient, EventRecorder) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory
 
create(Configuration, ExecutorService) - Static method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
 
create(MetricRegistry, Configuration, String, String, String) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
CREATED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
createFlinkDeploymentMetricManager(FlinkConfigManager, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
createFlinkSessionJobMetricManager(FlinkConfigManager, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
createHistogram(FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
createMetricConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
createNamespacedKubeClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
 
createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
Generate the config that is currently deployed for the resource spec.
createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
 
createOperator() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
 
createOrUpdateEvent(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils
 
createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
 
createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
 
createResourceGroup(Configuration, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
 
createResourceMetricGroup(KubernetesOperatorMetricGroup, FlinkConfigManager, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
createResourceNamespaceGroup(Configuration, Class<? extends AbstractFlinkResource>, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
createSavepointError(SavepointInfo, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 
createTaskManagerDeployment(Deployment) - Method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
 
createTaskManagerDeployment(Deployment) - Method in interface org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient
 
current() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
Returns the current version.
CURRENT_PROCESSING_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Current processing rate.
CustomCheckpointingStatisticsHeaders - Class in org.apache.flink.kubernetes.operator.service
Custom Headers for handling checkpoint history in a multi-version compatible way.
CustomCheckpointingStatisticsHeaders() - Constructor for class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
CustomDashboardConfiguration - Class in org.apache.flink.kubernetes.operator.service
Custom Response for handling dashboard configs.
CustomDashboardConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration
 
CustomDashboardConfigurationHeaders - Class in org.apache.flink.kubernetes.operator.service
Message headers for the CustomDashboardConfiguration.
CustomResourceMetrics<CR extends io.fabric8.kubernetes.client.CustomResource<?,​?>> - Interface in org.apache.flink.kubernetes.operator.metrics
Custom resource metric type.

D

dec() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
 
dec(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
 
decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
 
decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator
 
decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.InitStandaloneTaskManagerDecorator
 
decorateFlinkPod(FlinkPod) - Method in class org.apache.flink.kubernetes.operator.kubeclient.decorators.UserLibMountDecorator
 
DEFAULT_CHECKPOINTING_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
DefaultRequestMutator<T extends io.fabric8.kubernetes.api.model.KubernetesResource> - Class in org.apache.flink.kubernetes.operator.admission.mutator
The default request mutator.
DefaultRequestMutator(Mutator<T>) - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator
 
DefaultRequestMutator(Mutator<T>, Cloner<T>) - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator
 
DefaultValidator - Class in org.apache.flink.kubernetes.operator.validation
Default validator implementation for FlinkDeployment.
DefaultValidator(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.validation.DefaultValidator
 
deleteClusterDeployment(ObjectMeta, FlinkDeploymentStatus, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
deleteClusterDeployment(ObjectMeta, FlinkDeploymentStatus, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
Delete Flink kubernetes cluster by deleting the kubernetes resources directly.
deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
deleteClusterInternal(ObjectMeta, Configuration, boolean, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
deleteHAData(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
deleteJobGraphInKubernetesHA(String, String, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
deleteJobGraphInZookeeperHA(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
deleteKubernetesHAMetadata(String, String, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
deleteZookeeperHAMetadata(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
deploy(FlinkResourceContext<CR>, SPEC, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Deploys the target resource spec to Kubernetes.
deploy(FlinkResourceContext<FlinkDeployment>, FlinkDeploymentSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
deploy(FlinkResourceContext<FlinkDeployment>, FlinkDeploymentSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
deploy(FlinkResourceContext<FlinkSessionJob>, FlinkSessionJobSpec, Configuration, Optional<String>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
deployApplicationCluster(ClusterSpecification, ApplicationConfiguration) - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor
 
deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
deployApplicationCluster(JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
DEPLOYED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
DEPLOYED - org.apache.flink.kubernetes.operator.api.status.ReconciliationState
The lastReconciledSpec is currently deployed.
DEPLOYED_NOT_READY - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
JobManager is running but not ready yet to receive REST API calls.
DEPLOYING - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
JobManager process is starting up.
DEPLOYMENT_READINESS_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
DEPLOYMENT_ROLLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
DeploymentFailedException - Exception in org.apache.flink.kubernetes.operator.exception
Exception to signal terminal deployment failure.
DeploymentFailedException(DeploymentCondition) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
DeploymentFailedException(ContainerStateWaiting) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
DeploymentFailedException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
deploySessionCluster(ClusterSpecification) - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor
 
deserialize(String) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
 
deserializeLastReconciledSpec() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
deserializeLastReconciledSpecWithMeta() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
deserializeLastStableSpec() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
deserializeLastStableSpecWithMeta() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
deserializeSpecWithMeta(String, Class<T>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
Deserializes the spec and custom metadata object from JSON.
Diff<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff
Contains the differences between two Diffable class fields.
Diff() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.Diff
 
Diffable<T> - Interface in org.apache.flink.kubernetes.operator.api.diff
Diffable classes can be compared with other Diffable objects for differences.
DiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff
Assists in implementing comparison of Diffable instances.
DiffBuilder(T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
DiffResult<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff
Contains a collection of the differences between two Diffable objects.
DiffType - Enum in org.apache.flink.kubernetes.operator.api.diff
Spec change type.
discoverListeners(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils
Load FlinkResourceListener implementations from the plugin directory.
discoverValidators(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils
 
disposeSavepoint(String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
disposeSavepoint(String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 

E

Edge - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics
Collected scaling metrics.
Edge() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.Edge
 
ENV_CONF_OVERRIDE_DIR - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_HOSTNAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_KUBERNETES_SERVICE_HOST - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_OPERATOR_NAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_OPERATOR_NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_WATCH_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_WEBHOOK_KEYSTORE_FILE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_WEBHOOK_KEYSTORE_PASSWORD - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_WEBHOOK_KEYSTORE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
ENV_WEBHOOK_SERVER_PORT - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
EnvUtils - Class in org.apache.flink.kubernetes.operator.utils
Util to get value from environments.
EnvUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EnvUtils
 
EPHEMERAL_STORAGE - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
 
equals(Object) - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
error(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
 
ERROR - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
Deployment in terminal error, requires spec change for reconciliation to continue.
escapeCharacters(String) - Static method in class org.apache.flink.kubernetes.operator.docs.util.Utils
 
evaluate(Configuration, Map<String, String>, ClusterHealthInfo) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
 
evaluate(Configuration, CollectedMetricHistory) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator
 
EvaluatedScalingMetric - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics
Evaluated scaling metric.
EvaluatedScalingMetric(double, double) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.EvaluatedScalingMetric
 
eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
 
eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
 
eventRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
EventRecorder - Class in org.apache.flink.kubernetes.operator.utils
Helper class for creating Kubernetes events for Flink resources.
EventRecorder(KubernetesClient, BiConsumer<AbstractFlinkResource<?, ?>, Event>) - Constructor for class org.apache.flink.kubernetes.operator.utils.EventRecorder
 
EventRecorder.Component - Enum in org.apache.flink.kubernetes.operator.utils
The component of events.
EventRecorder.Reason - Enum in org.apache.flink.kubernetes.operator.utils
The reason codes of events.
EventRecorder.Type - Enum in org.apache.flink.kubernetes.operator.utils
The type of the events.
EventSourceUtils - Class in org.apache.flink.kubernetes.operator.utils
Utility class to locate secondary resources.
EventSourceUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
 
EventUtils - Class in org.apache.flink.kubernetes.operator.utils
The util to generate an event for the target resource.
EventUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventUtils
 
EXPECTED_PROCESSING_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Expected true processing rate after scale up.

F

Fabric8FlinkStandaloneKubeClient - Class in org.apache.flink.kubernetes.operator.kubeclient
The Implementation of FlinkStandaloneKubeClient.
Fabric8FlinkStandaloneKubeClient(Configuration, NamespacedKubernetesClient, ExecutorService) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
 
FAILED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
failedReconciliation(ResourceID, Exception, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
fetch(String, Configuration, File) - Method in interface org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher
Fetch the resource from the uri to the targetDir.
fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
 
fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
 
fetch(String, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager
 
fetchSavepointInfo(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
fetchSavepointInfo(String, String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
FIELD_NAME_ACC_BACK_PRESSURE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_ACC_BUSY - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_ACC_IDLE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_BYTES_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_BYTES_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_FLINK_REVISION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration
 
FIELD_NAME_FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration
 
FIELD_NAME_FORMAT_TYPE - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
FIELD_NAME_RECORDS_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_RECORDS_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
 
FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
FIELD_NAME_TOTAL_CPU - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
FIELD_NAME_TOTAL_MEMORY - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
FileSystemBasedArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact
Leverage the flink filesystem plugin to fetch the artifact.
FileSystemBasedArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
 
FileSystemWatchService - Class in org.apache.flink.kubernetes.operator.fs
Service which is able to watch local filesystem directories.
FileSystemWatchService(String) - Constructor for class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
 
filterTargetJob(JobStatus, List<JobStatusMessage>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
Filter the target job status message by the job list from the cluster.
findAny(Collection<AggregatedMetric>) - Method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 
finishedReconciliation(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
FLINK_VERSION_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
FlinkConfigBuilder - Class in org.apache.flink.kubernetes.operator.config
Builder to get effective flink config from FlinkDeployment.
FlinkConfigBuilder(String, String, FlinkDeploymentSpec, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
FlinkConfigBuilder(FlinkDeployment, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
FlinkConfigManager - Class in org.apache.flink.kubernetes.operator.config
Configuration manager for the Flink operator.
FlinkConfigManager(Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
FlinkConfigManager(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
FlinkConfigManager(Configuration, Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
FlinkDeployment - Class in org.apache.flink.kubernetes.operator.api
Custom resource definition that represents both Application and Session deployments.
FlinkDeployment() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkDeployment
 
FlinkDeploymentContext - Class in org.apache.flink.kubernetes.operator.controller
Context for reconciling a Flink resource.
FlinkDeploymentContext(FlinkDeployment, Context<?>, KubernetesResourceMetricGroup, FlinkService, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
 
FlinkDeploymentController - Class in org.apache.flink.kubernetes.operator.controller
Controller that runs the main reconcile loop for Flink deployments.
FlinkDeploymentController(FlinkConfigManager, Set<FlinkResourceValidator>, FlinkResourceContextFactory, ReconcilerFactory, FlinkDeploymentObserverFactory, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, EventRecorder, CanaryResourceManager<FlinkDeployment>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
 
FlinkDeploymentList - Class in org.apache.flink.kubernetes.operator.api
Multiple Flink deployments.
FlinkDeploymentList() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkDeploymentList
 
FlinkDeploymentMetrics - Class in org.apache.flink.kubernetes.operator.metrics
FlinkDeployment metrics.
FlinkDeploymentMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
FlinkDeploymentObserverFactory - Class in org.apache.flink.kubernetes.operator.observer.deployment
The factory to create the observer based on the FlinkDeployment mode.
FlinkDeploymentObserverFactory(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory
 
FlinkDeploymentReconciliationStatus - Class in org.apache.flink.kubernetes.operator.api.status
Status of the last reconcile step for the flink deployment.
FlinkDeploymentReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentReconciliationStatus
 
FlinkDeploymentSpec - Class in org.apache.flink.kubernetes.operator.api.spec
Spec that describes a Flink application or session cluster deployment.
FlinkDeploymentSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec
 
FlinkDeploymentStatus - Class in org.apache.flink.kubernetes.operator.api.status
Last observed status of the Flink deployment.
FlinkDeploymentStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus
 
FlinkMetric - Enum in org.apache.flink.kubernetes.operator.autoscaler.metrics
Enum representing the collected Flink metrics for autoscaling.
FlinkMutator - Class in org.apache.flink.kubernetes.operator.admission.mutator
The default mutator.
FlinkMutator() - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator
 
FlinkOperator - Class in org.apache.flink.kubernetes.operator
Main Class for Flink native k8s operator.
FlinkOperator(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.FlinkOperator
 
FlinkOperatorConfiguration - Class in org.apache.flink.kubernetes.operator.config
Configuration class for operator.
FlinkOperatorConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration
 
FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration - Class in org.apache.flink.kubernetes.operator.config
Enables configurable retry mechanism for reconciliation errors.
FlinkOperatorRetryConfiguration(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
 
FlinkOperatorWebhook - Class in org.apache.flink.kubernetes.operator.admission
Main Class for Flink native k8s operator.
FlinkOperatorWebhook() - Constructor for class org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook
 
FlinkResourceContext<CR extends AbstractFlinkResource<?,​?>> - Class in org.apache.flink.kubernetes.operator.controller
Context for reconciling a Flink resource.
FlinkResourceContext() - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
 
FlinkResourceContextFactory - Class in org.apache.flink.kubernetes.operator.service
Factory for creating the FlinkResourceContext.
FlinkResourceContextFactory(KubernetesClient, FlinkConfigManager, KubernetesOperatorMetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
 
FlinkResourceException - Class in org.apache.flink.kubernetes.operator.exception
Exception to display as JSON in CRD.
FlinkResourceException() - Constructor for class org.apache.flink.kubernetes.operator.exception.FlinkResourceException
 
FlinkResourceExceptionUtils - Class in org.apache.flink.kubernetes.operator.utils
Flink Resource Exception utilities.
FlinkResourceExceptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
 
FlinkResourceListener - Interface in org.apache.flink.kubernetes.operator.api.listener
Listener interface for Flink resource related events and status changes.
FlinkResourceListener.ResourceContext<R extends AbstractFlinkResource<?,​?>> - Interface in org.apache.flink.kubernetes.operator.api.listener
Base for Resource Event and StatusUpdate contexts.
FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,​?>> - Interface in org.apache.flink.kubernetes.operator.api.listener
Context for Resource Event listener methods.
FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,​S>,​S extends CommonStatus<?>> - Interface in org.apache.flink.kubernetes.operator.api.listener
Context for Status listener methods.
FlinkResourceValidator - Interface in org.apache.flink.kubernetes.operator.validation
Validator for different resources.
FlinkService - Interface in org.apache.flink.kubernetes.operator.service
Service for submitting and interacting with Flink clusters and jobs.
FlinkSessionJob - Class in org.apache.flink.kubernetes.operator.api
Custom resource definition that represents a flink session job.
FlinkSessionJob() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkSessionJob
 
FlinkSessionJobContext - Class in org.apache.flink.kubernetes.operator.controller
Context for reconciling a Flink resource.
FlinkSessionJobContext(FlinkSessionJob, Context<?>, KubernetesResourceMetricGroup, FlinkResourceContextFactory, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
 
FlinkSessionJobController - Class in org.apache.flink.kubernetes.operator.controller
Controller that runs the main reconcile loop for FlinkSessionJob.
FlinkSessionJobController(FlinkConfigManager, Set<FlinkResourceValidator>, FlinkResourceContextFactory, Reconciler<FlinkSessionJob>, Observer<FlinkSessionJob>, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, EventRecorder, CanaryResourceManager<FlinkSessionJob>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
 
FlinkSessionJobList - Class in org.apache.flink.kubernetes.operator.api
Multiple Flink session jobs.
FlinkSessionJobList() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkSessionJobList
 
FlinkSessionJobMetrics - Class in org.apache.flink.kubernetes.operator.metrics
FlinkSessionJob metrics.
FlinkSessionJobMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
 
FlinkSessionJobObserver - Class in org.apache.flink.kubernetes.operator.observer.sessionjob
The observer of FlinkSessionJob.
FlinkSessionJobObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
 
FlinkSessionJobReconciliationStatus - Class in org.apache.flink.kubernetes.operator.api.status
Status of the last reconcile step for the flink sessionjob.
FlinkSessionJobReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobReconciliationStatus
 
FlinkSessionJobSpec - Class in org.apache.flink.kubernetes.operator.api.spec
Spec that describes a Flink session job.
FlinkSessionJobSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec
 
FlinkSessionJobStatus - Class in org.apache.flink.kubernetes.operator.api.status
Last observed status of the Flink Session job.
FlinkSessionJobStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus
 
FlinkStandaloneKubeClient - Interface in org.apache.flink.kubernetes.operator.kubeclient
Extension of the FlinkKubeClient that is used for Flink standalone deployments.
FlinkUtils - Class in org.apache.flink.kubernetes.operator.utils
Flink Utility methods used by the operator.
FlinkUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
FlinkValidator - Class in org.apache.flink.kubernetes.operator.admission
Validator for FlinkDeployment creation and updates.
FlinkValidator(Set<FlinkResourceValidator>, InformerManager) - Constructor for class org.apache.flink.kubernetes.operator.admission.FlinkValidator
 
FlinkVersion - Enum in org.apache.flink.kubernetes.operator.api.spec
Enumeration for supported Flink versions.
flinkVersionChanged(SPEC, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
format(Event) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils
 
formatScope(String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
 
formatScope(String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
 
formatScope(String, String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
 
forResource(AbstractFlinkResource<?, ?>, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
from - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
 
from(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata
 
fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
 
fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
 
fromConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
 
fromConfig(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService
 
fromConfiguration(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration
 
fromJsonPlan(String, Map<JobVertexID, Integer>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
 
fromRuntimeInfo(RuntimeInfo) - Static method in class org.apache.flink.kubernetes.operator.health.InformerHealthSummary
 

G

GENERATED_FILE_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
 
generateEventName(HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils
 
generateJarDir(ObjectMeta, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager
 
generateSessionJobFixedJobID(ObjectMeta) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
The jobID's lower part is the resource uid, the higher part is the resource generation.
generateSessionJobFixedJobID(String, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
The jobID's lower part is the resource uid, the higher part is the resource generation.
get(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils
Get the value provided by environments.
get(AggregatedMetric) - Method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator
 
getAccumulatedBackpressured() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getAccumulatedBusy() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getAccumulatedIdle() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getAllowNonRestoredState() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getAnnotations() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getAvailableUpgradeMode(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
getAvailableUpgradeMode(FlinkResourceContext<FlinkDeployment>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
getAvailableVertexMetricNames() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
getBytesRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getBytesWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getCache() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
getCheckpointInfo(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getCheckpointInfo(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getClearedStatesAfterTransition(ResourceLifecycleState) - Method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
getClusterClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getClusterClient(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getClusterDescription() - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor
 
getClusterInfo(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getClusterInfo(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getCommonLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getCommonLabels(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
 
getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram
 
getCount() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
 
getCpuLimitFactor() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getCurrentState() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
 
getDefaultConfig() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
getDeployConfig(ObjectMeta, FlinkDeploymentSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
 
getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
 
getDeployedGeneration(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
getDeployedSpec(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
getDeploymentInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
 
getDeploymentMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
 
getDeploymentMode(FlinkDeploymentSpec) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
 
getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getEffectiveStatus(JobDetails) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getEnvironments() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getEvent() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext
 
getFilteredVertexMetricNames(RestClusterClient<?>, JobID, JobVertexID, JobTopology) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
Query and filter metric names for a given job vertex.
getFlinkDepInformer(String) - Method in class org.apache.flink.kubernetes.operator.admission.informer.InformerManager
 
getFlinkDeploymentInformerEventSource(EventSourceContext<FlinkSessionJob>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
 
getFlinkResource() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
 
getFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
Get the FlinkService implementation for the current resource.
getFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
 
getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
 
getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
 
getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
 
getHistories() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getIngressUrl(String, String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils
 
getInitialInterval() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
 
getInProgressCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper
 
getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getIntervalMultiplier() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
 
getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
getJmPodList(FlinkDeployment, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getJmPodList(FlinkDeployment, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getJobManagerDeploymentName(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
getJobManagerSelectors(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
getJobSpecArgs() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getJobTopology(FlinkService, AbstractFlinkResource<?, ?>, Configuration, AutoScalerInfo) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
 
getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getKubernetesClient(FlinkOperatorConfiguration, MetricGroup) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
 
getKubernetesClient(FlinkOperatorConfiguration, MetricGroup, Config) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
 
getLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getLastCheckpoint(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getLastCheckpoint(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getLastSavepointStatus(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 
getLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
 
getLatestCompletedCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper
 
getLifecycleState() - Method in class org.apache.flink.kubernetes.operator.api.status.CommonStatus
 
getLifecycleTrackers() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
 
getMainClass() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getMaxAttempts() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
 
getMaxInterval() - Method in class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration
 
getMemoryLimitFactor() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getMetricHistory() - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
getMetrics(Configuration, String, List<String>) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getMetrics(Configuration, String, List<String>) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
getMetricWindowSize(Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
getMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode
Return the mode of the given FlinkDeployment for Observer and Reconciler.
getName() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
 
getNewStatus() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext
 
getNodeSelector() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getNumberOfActiveCanaries() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
getNumDiffs() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult
 
getNumTaskManagers(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
getNumTaskManagers(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
getObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
Get the config that is currently deployed for the resource spec.
getObserveConfig(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
getOperatorConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory
 
getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory
 
getOrCreateFlinkService(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
 
getOrDefault(String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils
Get the value or default value provided by environments.
getOwnerReference() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getPodTemplateFilePath() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getPreviousStatus() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext
 
getRate() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
 
getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException
 
getReconciliationStatus() - Method in class org.apache.flink.kubernetes.operator.api.status.CommonStatus
Current reconciliation status of this resource.
getRecordsRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getRecordsWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
getRegisteredMetrics() - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
getReplicas() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getRequestClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getRequestClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getRequired(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils
Get the value provided by environments.
getResourceContext(CR, Context) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
 
getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getRPCPort() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getSavepointFormatType(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 
getSavepointPath() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getScalingHistory(Instant, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
getSelectors() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
getSelectors() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getServiceAccount() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getSessionJobConfig(FlinkDeployment, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
getSessionJobInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
 
getSpecClass() - Method in class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentReconciliationStatus
 
getSpecClass() - Method in class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobReconciliationStatus
 
getSpecClass() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
getStateTimeHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
 
getStatistics() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram
 
getSubstringWithMaxLength(String, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
 
getSupportedOptions() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
 
getSupportedSourceVersion() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
 
getTargetDirectory() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
 
getTargetDirectory() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
getTargetProcessingCapacity(Map<ScalingMetric, EvaluatedScalingMetric>, Configuration, double, boolean) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.utils.AutoScalerUtils
 
getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getTaskManagerCPU() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getTaskManagerDeploymentName(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
getTaskManagerMemoryMB() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getTaskManagerSelectors(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
getTaskManagersInfo(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
getTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
 
getTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext
 
getTolerations() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
getTopologies() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
getTransitionHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
 
getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
 
getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
getUpgradeTargetGeneration(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Get spec generation for the current in progress upgrade.
getValueWithThreshold(Configuration, ConfigOption<T>, T) - Static method in class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils
Gets the value of ConfigOption with threshold.
getVerticesInTopologicalOrder() - Method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
 
gracePeriodEnded(Configuration, SavepointInfo) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 

H

handle(AdmissionRequest) - Method in class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator
 
handleCanaryResourceDeletion(CR) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
handleCanaryResourceReconciliation(CR) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
hashCode() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
HealthProbe - Enum in org.apache.flink.kubernetes.operator.health
Flink operator health probe.
HISTO - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
hostname - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
HTTP_REQUEST_FAILED_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_REQUEST_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_RESPONSE_1XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_RESPONSE_2XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_RESPONSE_3XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_RESPONSE_4XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_RESPONSE_5XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HTTP_RESPONSE_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
HttpArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact
Download the jar from the http resource.
HttpArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
 
HttpBootstrap - Class in org.apache.flink.kubernetes.operator.health
Class for serving HTTP requests for the health probe.
HttpBootstrap(HealthProbe, int) - Constructor for class org.apache.flink.kubernetes.operator.health.HttpBootstrap
 

I

IGNORE - org.apache.flink.kubernetes.operator.api.diff.DiffType
Ignorable spec change.
inc() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
 
inc(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
 
IneffectiveScaling - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
InformerHealthSummary - Class in org.apache.flink.kubernetes.operator.health
Operator informer health summary.
InformerHealthSummary() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerHealthSummary
 
InformerIdentifier - Class in org.apache.flink.kubernetes.operator.health
Operator informer identifier.
InformerIdentifier() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerIdentifier
 
InformerManager - Class in org.apache.flink.kubernetes.operator.admission.informer
The manager of the informers.
InformerManager(KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.admission.informer.InformerManager
 
ingressInNetworkingV1(KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils
 
IngressSpec - Class in org.apache.flink.kubernetes.operator.api.spec
Ingress spec.
IngressSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.IngressSpec
 
IngressUtils - Class in org.apache.flink.kubernetes.operator.utils
Ingress utilities.
IngressUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.IngressUtils
 
init(Locale, Reporter) - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
 
initOperatorMetrics(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
initSpec() - Method in class org.apache.flink.kubernetes.operator.api.FlinkDeployment
 
initSpec() - Method in class org.apache.flink.kubernetes.operator.api.FlinkSessionJob
 
InitStandaloneTaskManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators
An initializer for the TaskManager FlinkPod in standalone mode.
InitStandaloneTaskManagerDecorator(StandaloneKubernetesTaskManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.InitStandaloneTaskManagerDecorator
 
initStatus() - Method in class org.apache.flink.kubernetes.operator.api.FlinkDeployment
 
initStatus() - Method in class org.apache.flink.kubernetes.operator.api.FlinkSessionJob
 
INNEFFECTIVE_MESSAGE_FORMAT - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler
 
INSTANCE - org.apache.flink.kubernetes.operator.health.HealthProbe
 
INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
 
INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
 
INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
 
intercept(Interceptor.Chain) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
INTERNAL_METADATA_JSON_KEY - Static variable in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
 
IOMetricsInfo - Class in org.apache.flink.runtime.rest.messages.job.metrics
IO metrics information.
IOMetricsInfo(long, boolean, long, boolean, long, boolean, long, boolean, Long, Long, Double) - Constructor for class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
isApplicationCluster() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
isAvailable() - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode
 
isBeforeFirstDeployment() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
isBytesReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
isBytesWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
isCalculateAverage() - Method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
 
isCanaryResource(HasMetadata) - Static method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
 
isCancelJob() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
 
isClient() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
isHAEnabled() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
isHaMetadataAvailable(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
isHaMetadataAvailable(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
isHealthy() - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe
 
isInternalServiceEnabled() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
isJmDeploymentReady(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
isJobInTerminalState(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
isJobManagerPortReady(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
isJobManagerPortReady(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
isJobRunning(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
isKubernetesHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
isKubernetesHaMetadataAvailable(Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
isLastReconciledSpecStable() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
isNewerVersionThan(FlinkVersion) - Method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
 
isPipelineClasspathDefined() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
isProcessingBacklog(JobTopology, SortedMap<Instant, CollectedMetrics>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator
 
isRecordsReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
isRecordsWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
 
isResourceReadyToBeObserved(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
Check whether the resource should be observed.
isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
 
isScaledUp() - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingSummary
 
isSource(JobVertexID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
 
isSuspendedJob(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
isUpgradeModeChangedToLastStateAndHADisabledPreviously(AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
isValid(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
 
isZookeeperHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
isZookeeperHaMetadataAvailable(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 

J

JAR_ARTIFACT_HTTP_HEADER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
jmPodNeverStarted(Context<?>) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
Check if the jobmanager pod has never successfully started.
Job - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
 
JOB_UPGRADE_IGNORE_PENDING_SAVEPOINT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
JobAutoScaler - Interface in org.apache.flink.kubernetes.operator.reconciler.deployment
Per-job Autoscaler instance.
JobAutoScalerFactory - Interface in org.apache.flink.kubernetes.operator.reconciler.deployment
Factory to construct a new autoscaler instance.
JobAutoscalerFactoryImpl - Class in org.apache.flink.kubernetes.operator.autoscaler
Factory for loading JobAutoScalerImpl included in this module.
JobAutoscalerFactoryImpl() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.JobAutoscalerFactoryImpl
 
JobAutoScalerImpl - Class in org.apache.flink.kubernetes.operator.autoscaler
Application and SessionJob autoscaler.
JobAutoScalerImpl(KubernetesClient, ScalingMetricCollector, ScalingMetricEvaluator, ScalingExecutor, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.JobAutoScalerImpl
 
JOBMANAGER_ENTRYPOINT_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
 
JobManagerDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
 
JobManagerDeploymentStatus - Enum in org.apache.flink.kubernetes.operator.api.status
Status of the Flink JobManager Kubernetes deployment.
JobManagerSpec - Class in org.apache.flink.kubernetes.operator.api.spec
JobManager spec.
JobManagerSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.JobManagerSpec
 
JobSpec - Class in org.apache.flink.kubernetes.operator.api.spec
Flink job spec.
JobSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.JobSpec
 
JobState - Enum in org.apache.flink.kubernetes.operator.api.spec
Enum describing the desired job state.
JobStatus - Class in org.apache.flink.kubernetes.operator.api.status
Last observed status of the Flink job within an application deployment.
JobStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.JobStatus
 
JobStatusChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
JobStatusObserver<R extends AbstractFlinkResource<?,​?>> - Class in org.apache.flink.kubernetes.operator.observer
An observer to observe the job status.
JobStatusObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
 
JobTopology - Class in org.apache.flink.kubernetes.operator.autoscaler.topology
Structure representing information about the jobgraph that is relevant for scaling.
JobTopology(Set<VertexInfo>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
 
JobTopology(VertexInfo...) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
 
JobVertexScaler - Class in org.apache.flink.kubernetes.operator.autoscaler
Component responsible for computing vertex parallelism based on the scaling metrics.
JobVertexScaler(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler
 

K

K8S_OP_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
KIND_FLINK_DEPLOYMENT - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
 
KIND_SESSION_JOB - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
 
KUBE_CLIENT_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
KUBERNETES_TASKMANAGER_REPLICAS - Static variable in class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
 
kubernetesClient - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
kubernetesClient - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
KubernetesClientMetrics - Class in org.apache.flink.kubernetes.operator.metrics
Kubernetes client metrics.
KubernetesClientMetrics(MetricGroup, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
KubernetesClientUtils - Class in org.apache.flink.kubernetes.operator.utils
Kubernetes client utils.
KubernetesClientUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
 
KubernetesDeploymentMode - Enum in org.apache.flink.kubernetes.operator.api.spec
Enum to control Flink deployment mode on Kubernetes.
KubernetesOperatorConfigOptions - Class in org.apache.flink.kubernetes.operator.config
This class holds configuration constants used by flink operator.
KubernetesOperatorConfigOptions() - Constructor for class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
KubernetesOperatorMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics
Base metric group for Flink Operator System metrics.
KubernetesOperatorMetricOptions - Class in org.apache.flink.kubernetes.operator.metrics
Configuration options for metrics.
KubernetesOperatorMetricOptions() - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
KubernetesOperatorScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics
Format for metrics.
KubernetesOperatorScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
 
KubernetesResourceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics
Base metric group for Flink Operator Resource level metrics.
KubernetesResourceMetricGroup(MetricRegistry, KubernetesResourceNamespaceMetricGroup, String[], String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
 
KubernetesResourceNamespaceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics
Base metric group for Flink Operator Resource namespace level metrics.
KubernetesResourceNamespaceMetricGroup(MetricRegistry, KubernetesOperatorMetricGroup, String[], String, String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
 
KubernetesResourceNamespaceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics
Format for metrics.
KubernetesResourceNamespaceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
 
KubernetesResourceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics
Format for metrics.
KubernetesResourceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
 
KubernetesStandaloneClusterDescriptor - Class in org.apache.flink.kubernetes.operator.standalone
Standalone Kubernetes specific ClusterDescriptor implementation.
KubernetesStandaloneClusterDescriptor(Configuration, FlinkStandaloneKubeClient) - Constructor for class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor
 

L

LABEL_TARGET_SESSION - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
 
LABEL_TYPE_STANDALONE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
LAG - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Total number of pending records.
LAST_STATE - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode
Job is upgraded using any latest checkpoint or savepoint available.
LifecycleMetrics<CR extends AbstractFlinkResource<?,​?>> - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle
Utility for tracking resource lifecycle metrics globally and per namespace.
LifecycleMetrics(FlinkConfigManager, KubernetesOperatorMetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
 
LifecycleMetrics.Transition - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle
Pojo for encapsulating state transitions and whether we should measure time from the beginning of from or since the last update.
ListenerUtils - Class in org.apache.flink.kubernetes.operator.listener
Flink resource listener utilities.
ListenerUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.ListenerUtils
 
listJobs(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
listJobs(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
LOAD_AVG - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Average subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).
LOAD_MAX - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Max subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).
loadGlobalConfiguration(Optional<String>) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
loadJobAutoscalerFactory() - Static method in class org.apache.flink.kubernetes.operator.utils.AutoscalerLoader
 
loadListenerConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils
 
LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
 
LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
 
logContext(FlinkResourceListener.ResourceEventContext<R>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils
 
logContext(FlinkResourceListener.StatusUpdateContext<R, S>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils
 
logEnvironmentInfo(Logger, String, String[]) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils
Logs information about the environment, like code revision, current user, Java version, and JVM parameters.
logger - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
 
logger - Variable in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 

M

main(String[]) - Static method in class autoscaling.AutoscalingExample
 
main(String[]) - Static method in class org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook
 
main(String[]) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
 
main(String[]) - Static method in class org.apache.flink.kubernetes.operator.docs.configuration.ConfigOptionsDocGenerator
This method generates html tables from set of classes containing ConfigOptions.
main(String...) - Static method in class org.apache.flink.kubernetes.operator.FlinkOperator
 
MANUAL - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
Savepoint manually triggered by changing the savepointTriggerNonce.
markEvent() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
 
markEvent(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
 
markReconciledSpecAsStable() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
max(DiffType, DiffType) - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType
 
MAX - org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator
 
MAX_CM_BYTES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
MAX_PARALLELISM - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Job vertex max parallelism.
MAX_SCALE_DOWN_FACTOR - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
MAX_SCALE_UP_FACTOR - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
measureFromLastUpdate - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
 
MEMORY_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
mergePodTemplates(Pod, Pod, boolean) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
METER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
 
MetricAggregator - Enum in org.apache.flink.kubernetes.operator.autoscaler.metrics
Enum specifying which aggregator to use when getting a metric value.
MetricManager<CR extends AbstractFlinkResource<?,​?>> - Class in org.apache.flink.kubernetes.operator.metrics
Metric manager for Operator managed custom resources.
MetricManager() - Constructor for class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
metricName - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
 
METRICS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
MIN - org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator
 
Missing - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
MISSING - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
JobManager deployment not found, probably not started or killed by user.
MISSING_SESSION_JOB_ERR - Static variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
 
MissingJobManagerException - Exception in org.apache.flink.kubernetes.operator.exception
Exception to signal missing job manager.
MissingJobManagerException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
 
MissingJobManagerException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
 
MissingJobManagerException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
 
MissingSessionJobException - Exception in org.apache.flink.kubernetes.operator.exception
Exception to signal missing session job.
MissingSessionJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
 
MissingSessionJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
 
MissingSessionJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
 
Mode - Enum in org.apache.flink.kubernetes.operator.config
The mode of FlinkDeployment.
monitorSizeOf(T, String) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
MSG_ROLLBACK - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
MSG_SPEC_CHANGED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
MSG_SUBMIT - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
MSG_SUSPENDED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
mutate(HasMetadata, Operation) - Method in class org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator
 
MUTATOR_REQUEST_PATH - Static variable in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
 

N

name - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
 
namespace - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
 
NATIVE - org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
Deploys Flink using Flinks native Kubernetes support.
NATIVE - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType
A format specific for the chosen state backend.
NativeFlinkService - Class in org.apache.flink.kubernetes.operator.service
Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.
NativeFlinkService(KubernetesClient, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
newEngine(ByteBufAllocator) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
newEngine(ByteBufAllocator, String, int) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
NoopJobAutoscalerFactory - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
An autoscaler implementation which does nothing.
NoopJobAutoscalerFactory() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory
 
Normal - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
 
NUM_RECORDS_IN_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 
NUM_RECORDS_OUT_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 

O

objectMapper - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
 
observe(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
 
observe(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.observer.Observer
Observe the flinkApp status, It will reflect the changed status on the flinkApp resource.
observe(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver
Observe the health of the flink cluster.
observe(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
Observe the status of the flink job.
observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
Observe the flinkApp status when the cluster is ready.
observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver
 
observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver
 
observeInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
Internal observer logic specific to each resource type.
observeInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
observeInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
 
observeJmDeployment(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
Observer<CR extends AbstractFlinkResource<?,​?>> - Interface in org.apache.flink.kubernetes.operator.observer
The Observer of custom resource.
observeSavepointStatus(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.SavepointObserver
 
of(double) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.EvaluatedScalingMetric
 
of(String, long, SavepointTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint
 
of(String, SavepointTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint
 
of(String, SavepointTriggerType, SavepointFormatType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint
 
onDeploymentEvent(FlinkResourceListener.ResourceEventContext<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
 
onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment, FlinkDeploymentStatus>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
 
onFileOrDirectoryCreated(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
 
onFileOrDirectoryDeleted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
 
onFileOrDirectoryModified(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
 
onNoJobsFound(R, Configuration) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
Callback when no jobs were found on the cluster.
onRemove(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics
 
onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
 
onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
onRemove(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
onRemove(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
 
onSessionJobEvent(FlinkResourceListener.ResourceEventContext<FlinkSessionJob>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
 
onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob, FlinkSessionJobStatus>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
 
onTargetJobNotFound(R, Configuration) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
Callback when no matching target job was found on a cluster where jobs were found.
onTimeout(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
Callback when list jobs timeout.
onUpdate(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics
 
onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
 
onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
onUpdate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
onUpdate(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
 
onUpdate(ResourceLifecycleState, Instant) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
 
onWatchStarted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
 
Operator - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
 
OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_CLUSTER_HEALTH_CHECK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_CONFIG_CACHE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_CONFIG_CACHE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_DYNAMIC_CONFIG_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_DYNAMIC_CONFIG_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_DYNAMIC_NAMESPACES_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_EXCEPTION_FIELD_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_EXCEPTION_STACK_TRACE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_EXCEPTION_STACK_TRACE_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_EXCEPTION_THROWABLE_LIST_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_FLINK_CLIENT_CANCEL_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_FLINK_CLIENT_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_HEALTH_PROBE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_HEALTH_PROBE_PORT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_JM_DEPLOYMENT_RECOVERY_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_JM_SHUTDOWN_TTL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_JOB_RESTART_FAILED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_JOB_UPGRADE_LAST_STATE_CHECKPOINT_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_JOB_UPGRADE_LAST_STATE_FALLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_JOSDK_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_JVM_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_KUBERNETES_CLIENT_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_KUBERNETES_CLIENT_METRICS_HTTP_RESPONSE_CODE_GROUPS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_LABEL_SELECTOR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_LEADER_ELECTION_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_LEADER_ELECTION_LEASE_DURATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_LEADER_ELECTION_LEASE_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_LEADER_ELECTION_RENEW_DEADLINE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_LEADER_ELECTION_RETRY_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_LIFECYCLE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_LIFECYCLE_NAMESPACE_HISTOGRAMS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_METRICS_HISTOGRAM_SAMPLE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_OBSERVER_PROGRESS_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_OBSERVER_REST_READY_DELAY - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_RECONCILE_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_RECONCILE_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_RESOURCE_CLEANUP_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_RESOURCE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
OPERATOR_RETRY_INITIAL_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_RETRY_INTERVAL_MULTIPLIER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_RETRY_MAX_ATTEMPTS - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_CLEANUP_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_FORMAT_TYPE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_HISTORY_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_HISTORY_MAX_AGE_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_SAVEPOINT_TRIGGER_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_STOP_ON_INFORMER_ERROR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_TERMINATION_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_USER_ARTIFACTS_BASE_DIR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OPERATOR_WATCHED_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
operatorConfig(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
operatorConfigKey(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
OperatorHealthHandler - Class in org.apache.flink.kubernetes.operator.health
Simple code which returns HTTP 200 messages if the service is live, and HTTP 500 messages if the service is down.
OperatorHealthHandler() - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler
 
OperatorHealthService - Class in org.apache.flink.kubernetes.operator.health
Health probe service.
OperatorHealthService(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthService
 
OperatorJosdkMetrics - Class in org.apache.flink.kubernetes.operator.metrics
Implementation of Metrics to monitor and forward JOSDK metrics to MetricRegistry.
OperatorJosdkMetrics(KubernetesOperatorMetricGroup, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
OperatorMetricUtils - Class in org.apache.flink.kubernetes.operator.metrics
Utility class for flink based operator metrics.
OperatorMetricUtils() - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
OperatorMetricUtils.SynchronizedCounter - Class in org.apache.flink.kubernetes.operator.metrics
Thread safe Counter wrapper.
OperatorMetricUtils.SynchronizedHistogram - Class in org.apache.flink.kubernetes.operator.metrics
Thread safe Histogram wrapper.
OperatorMetricUtils.SynchronizedMeterView - Class in org.apache.flink.kubernetes.operator.metrics
Thread safe MeterView wrapper.
org.apache.flink.kubernetes.operator - package org.apache.flink.kubernetes.operator
 
org.apache.flink.kubernetes.operator.admission - package org.apache.flink.kubernetes.operator.admission
 
org.apache.flink.kubernetes.operator.admission.informer - package org.apache.flink.kubernetes.operator.admission.informer
 
org.apache.flink.kubernetes.operator.admission.mutator - package org.apache.flink.kubernetes.operator.admission.mutator
 
org.apache.flink.kubernetes.operator.api - package org.apache.flink.kubernetes.operator.api
 
org.apache.flink.kubernetes.operator.api.diff - package org.apache.flink.kubernetes.operator.api.diff
 
org.apache.flink.kubernetes.operator.api.docs - package org.apache.flink.kubernetes.operator.api.docs
 
org.apache.flink.kubernetes.operator.api.lifecycle - package org.apache.flink.kubernetes.operator.api.lifecycle
 
org.apache.flink.kubernetes.operator.api.listener - package org.apache.flink.kubernetes.operator.api.listener
 
org.apache.flink.kubernetes.operator.api.reconciler - package org.apache.flink.kubernetes.operator.api.reconciler
 
org.apache.flink.kubernetes.operator.api.spec - package org.apache.flink.kubernetes.operator.api.spec
 
org.apache.flink.kubernetes.operator.api.status - package org.apache.flink.kubernetes.operator.api.status
 
org.apache.flink.kubernetes.operator.api.utils - package org.apache.flink.kubernetes.operator.api.utils
 
org.apache.flink.kubernetes.operator.api.validation - package org.apache.flink.kubernetes.operator.api.validation
 
org.apache.flink.kubernetes.operator.artifact - package org.apache.flink.kubernetes.operator.artifact
 
org.apache.flink.kubernetes.operator.autoscaler - package org.apache.flink.kubernetes.operator.autoscaler
 
org.apache.flink.kubernetes.operator.autoscaler.config - package org.apache.flink.kubernetes.operator.autoscaler.config
 
org.apache.flink.kubernetes.operator.autoscaler.metrics - package org.apache.flink.kubernetes.operator.autoscaler.metrics
 
org.apache.flink.kubernetes.operator.autoscaler.topology - package org.apache.flink.kubernetes.operator.autoscaler.topology
 
org.apache.flink.kubernetes.operator.autoscaler.utils - package org.apache.flink.kubernetes.operator.autoscaler.utils
 
org.apache.flink.kubernetes.operator.config - package org.apache.flink.kubernetes.operator.config
 
org.apache.flink.kubernetes.operator.controller - package org.apache.flink.kubernetes.operator.controller
 
org.apache.flink.kubernetes.operator.docs.configuration - package org.apache.flink.kubernetes.operator.docs.configuration
 
org.apache.flink.kubernetes.operator.docs.util - package org.apache.flink.kubernetes.operator.docs.util
 
org.apache.flink.kubernetes.operator.exception - package org.apache.flink.kubernetes.operator.exception
 
org.apache.flink.kubernetes.operator.fs - package org.apache.flink.kubernetes.operator.fs
 
org.apache.flink.kubernetes.operator.health - package org.apache.flink.kubernetes.operator.health
 
org.apache.flink.kubernetes.operator.kubeclient - package org.apache.flink.kubernetes.operator.kubeclient
 
org.apache.flink.kubernetes.operator.kubeclient.decorators - package org.apache.flink.kubernetes.operator.kubeclient.decorators
 
org.apache.flink.kubernetes.operator.kubeclient.factory - package org.apache.flink.kubernetes.operator.kubeclient.factory
 
org.apache.flink.kubernetes.operator.kubeclient.parameters - package org.apache.flink.kubernetes.operator.kubeclient.parameters
 
org.apache.flink.kubernetes.operator.listener - package org.apache.flink.kubernetes.operator.listener
 
org.apache.flink.kubernetes.operator.metrics - package org.apache.flink.kubernetes.operator.metrics
 
org.apache.flink.kubernetes.operator.metrics.lifecycle - package org.apache.flink.kubernetes.operator.metrics.lifecycle
 
org.apache.flink.kubernetes.operator.observer - package org.apache.flink.kubernetes.operator.observer
 
org.apache.flink.kubernetes.operator.observer.deployment - package org.apache.flink.kubernetes.operator.observer.deployment
 
org.apache.flink.kubernetes.operator.observer.sessionjob - package org.apache.flink.kubernetes.operator.observer.sessionjob
 
org.apache.flink.kubernetes.operator.reconciler - package org.apache.flink.kubernetes.operator.reconciler
 
org.apache.flink.kubernetes.operator.reconciler.deployment - package org.apache.flink.kubernetes.operator.reconciler.deployment
 
org.apache.flink.kubernetes.operator.reconciler.diff - package org.apache.flink.kubernetes.operator.reconciler.diff
 
org.apache.flink.kubernetes.operator.reconciler.sessionjob - package org.apache.flink.kubernetes.operator.reconciler.sessionjob
 
org.apache.flink.kubernetes.operator.service - package org.apache.flink.kubernetes.operator.service
 
org.apache.flink.kubernetes.operator.ssl - package org.apache.flink.kubernetes.operator.ssl
 
org.apache.flink.kubernetes.operator.standalone - package org.apache.flink.kubernetes.operator.standalone
 
org.apache.flink.kubernetes.operator.utils - package org.apache.flink.kubernetes.operator.utils
 
org.apache.flink.kubernetes.operator.validation - package org.apache.flink.kubernetes.operator.validation
 
org.apache.flink.runtime.rest.messages.job.metrics - package org.apache.flink.runtime.rest.messages.job.metrics
 
org.apache.flink.runtime.rest.messages.job.savepoints - package org.apache.flink.runtime.rest.messages.job.savepoints
 
org.apache.flink.runtime.rest.messages.job.savepoints.stop - package org.apache.flink.runtime.rest.messages.job.savepoints.stop
 

P

PARALLELISM - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Job vertex parallelism.
PARALLELISM_OVERRIDES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
patchAndCacheStatus(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
Update the status of the provided kubernetes resource on the k8s cluster.
pending() - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
 
PENDING - org.apache.flink.kubernetes.operator.utils.SavepointStatus
Savepoint is pending, could be in the retry phase in the case of manual savepoint.
PENDING_RECORDS - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 
PendingCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.PendingCheckpointInfo
 
PERIODIC - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
Savepoint periodically triggered by the operator.
PERIODIC_SAVEPOINT_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
POD_IP_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
 
POD_TEMPLATE_MERGE_BY_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
predicate - Variable in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 
prefix() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry
 
prepareEventSources(EventSourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
 
prepareEventSources(EventSourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
 
putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
 
putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
 
putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
 

Q

queryAggregatedMetricNames(RestClusterClient<?>, JobID, JobVertexID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
queryAggregatedVertexMetrics(FlinkService, AbstractFlinkResource<?, ?>, Configuration, JobVertexID, Map<String, FlinkMetric>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector
 
queryAllAggregatedMetrics(AbstractFlinkResource<?, ?>, FlinkService, Configuration, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector
 
queryAllAggregatedMetrics(AbstractFlinkResource<?, ?>, FlinkService, Configuration, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
queryFilteredMetricNames(FlinkService, AbstractFlinkResource<?, ?>, Configuration, JobTopology) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
Query the available metric names for each job vertex for the current spec generation.
queryJobTopology(RestClusterClient<String>, JobID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 

R

READY - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
JobManager is running and ready to receive REST API calls.
readyToReconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Check whether the given Flink resource is ready to be reconciled or we are still waiting for any pending operation or condition first.
readyToReconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
readyToReconcile(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
readyToReconcile(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
REASON_CRASH_LOOP_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
REASON_ERR_IMAGE_PULL - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
REASON_IMAGE_PULL_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
 
receivedEvent(Event, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
reconcile(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
 
reconcile(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
 
reconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
reconcile(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler
This is called when receiving the create or update event of the custom resource.
reconcileCustomResource(ResourceID, RetryInfo, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Reconcile any other changes required for this resource that are specific to the reconciler implementation.
reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
 
reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
Reconciler<CR extends AbstractFlinkResource<?,​?>> - Interface in org.apache.flink.kubernetes.operator.reconciler
The interface of reconciler.
ReconcilerFactory - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
The factory to create reconciler based on app mode.
ReconcilerFactory(KubernetesClient, FlinkConfigManager, EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScalerFactory) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory
 
reconcileSpecChange(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Reconcile spec upgrade on the currently deployed/suspended Flink resource and update the status accordingly.
reconcileSpecChange(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
reconcileSpecChange(FlinkResourceContext<FlinkDeployment>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
ReconciliationException - Exception in org.apache.flink.kubernetes.operator.exception
Exception for wrapping reconciliation errors.
ReconciliationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException
 
ReconciliationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException
 
ReconciliationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException
 
ReconciliationMetadata - Class in org.apache.flink.kubernetes.operator.api.reconciler
Extra metadata to be attached to the reconciled spec.
ReconciliationMetadata() - Constructor for class org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata
 
ReconciliationState - Enum in org.apache.flink.kubernetes.operator.api.status
Current state of the reconciliation.
ReconciliationStatus<SPEC extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.status
Status of the last reconcile step for the FlinkDeployment/FlinkSessionJob.
ReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
ReconciliationUtils - Class in org.apache.flink.kubernetes.operator.reconciler
Reconciliation utilities.
ReconciliationUtils() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
RecoverDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
RecoveryFailureException - Exception in org.apache.flink.kubernetes.operator.exception
Exception to signal non-terminal deployment failure.
RecoveryFailureException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException
 
ReflectiveDiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff
Assists in comparing Diffable objects with reflection.
ReflectiveDiffBuilder(T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder
 
register(CustomResourceMetrics<CR>) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
 
registerCanaryResourceManager(CanaryResourceManager<?>) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe
 
registerScalingMetrics(Supplier<Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFlinkMetrics
 
reload() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
ReloadableSslContext - Class in org.apache.flink.kubernetes.operator.ssl
SSL context which is able to reload keystore.
ReloadableSslContext(String, String, String) - Constructor for class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
removeCachedStatus(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
Remove cached status for Flink resource.
removeLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
 
removeOperatorConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
replaceInKubernetes(KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
requestJobResult(Configuration, JobID) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
requestJobResult(Configuration, JobID) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
rescheduleAfter(JobManagerDeploymentStatus, FlinkDeployment, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
resetTrigger() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
 
resetTriggerIfJobNotRunning(AbstractFlinkResource<?, ?>, EventRecorder) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 
Resource - Class in org.apache.flink.kubernetes.operator.api.spec
Resource spec.
Resource() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.Resource
 
RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
 
RESOURCE_DELETION_PROPAGATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
RESOURCE_NS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
 
RESOURCE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
 
RESOURCE_USAGE_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
ResourceLifecycleMetricTracker - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle
Lifecycle state transition tracker for a single resource.
ResourceLifecycleMetricTracker(ResourceLifecycleState, Instant, Map<String, List<Histogram>>, Map<ResourceLifecycleState, List<Histogram>>) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
 
ResourceLifecycleState - Enum in org.apache.flink.kubernetes.operator.api.lifecycle
Enum encapsulating the lifecycle state of a Flink resource.
resourceMetricGroups - Variable in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
 
resourceScaler - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
RestApiMetricsCollector - Class in org.apache.flink.kubernetes.operator.autoscaler
Metric collector using flink rest api.
RestApiMetricsCollector() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.RestApiMetricsCollector
 
RESTART_TIME - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
RestartUnhealthyJob - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
restoreJob(FlinkResourceContext<CR>, SPEC, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
resubmitJob(FlinkResourceContext<CR>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
rollback(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Rollback deployed resource to the last stable spec.
rollback(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
 
rollback(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
Rollback - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
ROLLED_BACK - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
ROLLED_BACK - org.apache.flink.kubernetes.operator.api.status.ReconciliationState
Rolled back to the lastStableSpec.
ROLLING_BACK - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
ROLLING_BACK - org.apache.flink.kubernetes.operator.api.status.ReconciliationState
In the process of rolling back to the lastStableSpec.
roundMetric(double) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics
 
run() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
 
run() - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
 
run(DocletEnvironment) - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
 
RUNNING - org.apache.flink.kubernetes.operator.api.spec.JobState
Job is expected to be processing data.

S

Savepoint - Class in org.apache.flink.kubernetes.operator.api.status
Represents information about a finished savepoint.
Savepoint(long, String, SavepointTriggerType, SavepointFormatType, Long) - Constructor for class org.apache.flink.kubernetes.operator.api.status.Savepoint
 
SAVEPOINT - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode
Job is upgraded by first taking a savepoint of the running job, shutting it down and restoring from the savepoint.
SavepointError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
SavepointFetchResult - Class in org.apache.flink.kubernetes.operator.observer
Result of a fetch savepoint operation.
SavepointFetchResult() - Constructor for class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
 
SavepointFormatType - Enum in org.apache.flink.kubernetes.operator.api.status
Savepoint format type.
SavepointInfo - Class in org.apache.flink.kubernetes.operator.api.status
Stores savepoint related information.
SavepointInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
 
savepointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 
SavepointObserver<CR extends AbstractFlinkResource<?,​STATUS>,​STATUS extends CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.observer
An observer of savepoint progress.
SavepointObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.SavepointObserver
 
SavepointStatus - Enum in org.apache.flink.kubernetes.operator.utils
Enum encapsulating the lifecycle state of a Flink resource.
SavepointTriggerRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints
RequestBody to trigger savepoints.
SavepointTriggerRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
 
SavepointTriggerType - Enum in org.apache.flink.kubernetes.operator.api.status
Savepoint trigger mechanism.
SavepointUtils - Class in org.apache.flink.kubernetes.operator.utils
Savepoint utilities.
SavepointUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.SavepointUtils
 
scale(int, int, double, int, int) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler
 
scale(ObjectMeta, JobSpec, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
scale(ObjectMeta, JobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
scale(FlinkResourceContext) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.NoopJobAutoscalerFactory
 
scale(FlinkResourceContext<? extends AbstractFlinkResource<?, ?>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobAutoScalerImpl
 
scale(FlinkResourceContext<? extends AbstractFlinkResource<?, ?>>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.deployment.JobAutoScaler
Called as part of the reconciliation loop.
SCALE - org.apache.flink.kubernetes.operator.api.diff.DiffType
Scalable spec change.
SCALE_DOWN_RATE_THRESHOLD - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Lower boundary of the target data rate range.
SCALE_UP_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
SCALE_UP_RATE_THRESHOLD - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Upper boundary of the target data rate range.
scaleResource(AbstractFlinkResource<?, ?>, AutoScalerInfo, Configuration, Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
SCALING_EFFECTIVENESS_DETECTION_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
SCALING_EFFECTIVENESS_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
SCALING_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
SCALING_HISTORY_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
SCALING_SUMMARY_ENTRY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
SCALING_SUMMARY_HEADER_SCALING_DISABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
SCALING_SUMMARY_HEADER_SCALING_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
ScalingExecutor - Class in org.apache.flink.kubernetes.operator.autoscaler
Class responsible for executing scaling decisions.
ScalingExecutor(KubernetesClient, JobVertexScaler, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
ScalingExecutor(KubernetesClient, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
ScalingMetric - Enum in org.apache.flink.kubernetes.operator.autoscaler.metrics
Supported scaling metrics.
ScalingMetricCollector - Class in org.apache.flink.kubernetes.operator.autoscaler
Metric collector using flink rest api.
ScalingMetricCollector() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
ScalingMetricEvaluator - Class in org.apache.flink.kubernetes.operator.autoscaler
Job scaling evaluator for autoscaler.
ScalingMetricEvaluator() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricEvaluator
 
ScalingMetrics - Class in org.apache.flink.kubernetes.operator.autoscaler.metrics
Utilities for computing scaling metrics based on Flink metrics.
ScalingMetrics() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetrics
 
ScalingReport - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
ScalingSummary - Class in org.apache.flink.kubernetes.operator.autoscaler
Scaling summary returned by the ScalingMetricEvaluator.
ScalingSummary(int, int, Map<ScalingMetric, EvaluatedScalingMetric>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.ScalingSummary
 
SCOPE_NAMING_KUBERNETES_OPERATOR - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCENS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
 
SECTION_ADVANCED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
SECTION_DYNAMIC - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
SECTION_SYSTEM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
 
sendResponse(ChannelHandlerContext, String) - Static method in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
 
serialize(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
 
serializeAndSetLastReconciledSpec(SPEC, AbstractFlinkResource<SPEC, ?>) - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
 
SESSION - org.apache.flink.kubernetes.operator.config.Mode
 
SESSION - org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
 
sessionClusterReady(Optional<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
sessionContext() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
 
SessionJobReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.sessionjob
The reconciler for the FlinkSessionJob.
SessionJobReconciler(KubernetesClient, EventRecorder, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
 
SessionObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment
The observer of the Mode.SESSION cluster.
SessionObserver(FlinkConfigManager, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver
 
SessionReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment
Reconciler responsible for handling the session cluster lifecycle according to the desired and current states.
SessionReconciler(KubernetesClient, EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
 
setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.autoscaler.JobVertexScaler
 
setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingExecutor
 
setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
setClock(Clock) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
setGenerationAnnotation(Configuration, Long) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
 
setLastValidClusterHealthInfo(Map<String, String>, ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
 
setNamespaces(Set<String>) - Method in class org.apache.flink.kubernetes.operator.admission.informer.InformerManager
 
setOwnerReference(CR, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
setRuntimeInfo(RuntimeInfo) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe
 
setTrigger(String, SavepointTriggerType, SavepointFormatType) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
 
shouldDrain() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
shouldRecoverDeployment(Configuration, FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
Checks whether the JobManager Kubernetes Deployment recovery logic should be initiated.
shouldTriggerSavepoint(AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
Checks whether savepoint should be triggered based on the current status and spec and if yes, returns the correct SavepointTriggerType.
SOURCE_DATA_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Incoming data rate to the source, e.g.
SOURCE_TASK_NUM_RECORDS_IN_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 
SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC - org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
 
SpecChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
SpecDiff - Annotation Type in org.apache.flink.kubernetes.operator.api.diff
Spec diff annotation.
SpecDiff.Config - Annotation Type in org.apache.flink.kubernetes.operator.api.diff
Spec diff config annotation.
SpecDiff.Entry - Annotation Type in org.apache.flink.kubernetes.operator.api.diff
Spec diff config annotation entry.
SpecUtils - Class in org.apache.flink.kubernetes.operator.api.utils
Spec utilities.
SpecUtils() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
 
SpecWithMeta<T extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.utils
Utility class for encapsulating Kubernetes resource spec and meta fields during serialization.
SpecWithMeta() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.SpecWithMeta
 
STABILIZATION_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
STABLE - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
STANDALONE - org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
Deploys Flink on-top of kubernetes in standalone mode.
StandaloneFlinkService - Class in org.apache.flink.kubernetes.operator.service
Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.
StandaloneFlinkService(KubernetesClient, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
StandaloneKubernetesConfigOptionsInternal - Class in org.apache.flink.kubernetes.operator.standalone
This class holds internal configuration constants used by flink operator when deploying flink clusters in standalone mode.
StandaloneKubernetesConfigOptionsInternal() - Constructor for class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
 
StandaloneKubernetesConfigOptionsInternal.ClusterMode - Enum in org.apache.flink.kubernetes.operator.standalone
The different modes that a Flink cluster can be deployed in.
StandaloneKubernetesJobManagerFactory - Class in org.apache.flink.kubernetes.operator.kubeclient.factory
Utility class for constructing all the Kubernetes for the JobManager deploying in standalone mode.
StandaloneKubernetesJobManagerFactory() - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory
 
StandaloneKubernetesJobManagerParameters - Class in org.apache.flink.kubernetes.operator.kubeclient.parameters
A Utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the JobManager deployment used for standalone cluster deployments.
StandaloneKubernetesJobManagerParameters(Configuration, ClusterSpecification) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
 
StandaloneKubernetesTaskManagerFactory - Class in org.apache.flink.kubernetes.operator.kubeclient.factory
Utility class for constructing the TaskManager Deployment when deploying in standalone mode.
StandaloneKubernetesTaskManagerFactory() - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesTaskManagerFactory
 
StandaloneKubernetesTaskManagerParameters - Class in org.apache.flink.kubernetes.operator.kubeclient.parameters
A utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the TaskManager deployment used for standalone deployments.
StandaloneKubernetesTaskManagerParameters(Configuration, ClusterSpecification) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
 
StandaloneKubernetesUtils - Class in org.apache.flink.kubernetes.operator.utils
Standalone Kubernetes Utils.
StandaloneKubernetesUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
 
start() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService
 
STATELESS - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode
Job is upgraded with empty state.
STATUS_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
 
statusCache - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
 
StatusConflictException - Exception in org.apache.flink.kubernetes.operator.exception
Exception for status updates.
StatusConflictException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.StatusConflictException
 
statusRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
 
StatusRecorder<CR extends AbstractFlinkResource<?,​STATUS>,​STATUS extends CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.utils
Helper class for status management and updates.
StatusRecorder(KubernetesClient, MetricManager<CR>, BiConsumer<CR, STATUS>) - Constructor for class org.apache.flink.kubernetes.operator.utils.StatusRecorder
 
stop() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
 
stop() - Method in class org.apache.flink.kubernetes.operator.health.HttpBootstrap
 
stop() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService
 
stopAndCleanupCluster(String) - Method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
 
StopWithSavepointRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints.stop
RequestBody for stopping a job with a savepoint.
StopWithSavepointRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
 
Submit - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
submitApplicationCluster(JobSpec, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
submitApplicationCluster(JobSpec, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
submitClusterInternal(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
submitClusterInternal(Configuration, Mode) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, Configuration, String) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
submitSessionCluster(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
 
submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
 
SUCCEEDED - org.apache.flink.kubernetes.operator.utils.SavepointStatus
Savepoint is completed successfully.
Suspended - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
SUSPENDED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
SUSPENDED - org.apache.flink.kubernetes.operator.api.spec.JobState
Processing is suspended with the intention of continuing later.
synchronizedCounter(Counter) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
SynchronizedCounter(Counter) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
 
SynchronizedHistogram(Histogram) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram
 
synchronizedMeterView(MeterView) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
 
SynchronizedMeterView(MeterView) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
 

T

TARGET_DATA_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Target processing rate of operators as derived from source inputs (records/sec).
TARGET_UTILIZATION - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
TARGET_UTILIZATION_BOUNDARY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
TASKMANAGER_ENTRYPOINT_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator
 
TaskManagerInfo - Class in org.apache.flink.kubernetes.operator.api.status
Last observed status of the Flink job within an application deployment.
TaskManagerInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.TaskManagerInfo
 
TaskManagerSpec - Class in org.apache.flink.kubernetes.operator.api.spec
TaskManager spec.
TaskManagerSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.TaskManagerSpec
 
testTriviallyEqual(boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
 
timeControllerExecution(Metrics.ControllerExecution<T>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
 
to - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
 
toErrorStatusUpdateControl(R, Optional<RetryInfo>, Exception, StatusRecorder<R, STATUS>, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Update the resource error status and metrics when the operator encountered an exception during reconciliation.
toString() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult
 
toUpdateControl(FlinkOperatorConfiguration, R, R, boolean) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
TRACKED_TRANSITIONS - Static variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
 
Transition() - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
 
triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
 
triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, EventRecorder.Component, String) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
 
triggerSavepoint(String, SavepointTriggerType, SavepointInfo, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
triggerSavepoint(String, SavepointTriggerType, SavepointInfo, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
triggerSavepointIfNeeded(FlinkService, AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SavepointUtils
Triggers any pending manual or periodic savepoints and updates the status accordingly.
trimHistoryToMaxCmSize() - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
TRUE_PROCESSING_RATE - org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Processing rate at full capacity (records/sec).
type() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry
 

U

UNKNOWN - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType
Savepoint format unknown, if the savepoint was not triggered by the operator.
UNKNOWN - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
Savepoint trigger mechanism unknown, such as savepoint retrieved directly from Flink job.
UnknownJobException - Exception in org.apache.flink.kubernetes.operator.exception
Exception to signal unrecognized job found.
UnknownJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException
 
UnknownJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException
 
UnknownJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException
 
update() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
 
update(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram
 
updateDefaultConfig(Configuration) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
 
updateErrorStatus(FlinkDeployment, Context<FlinkDeployment>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
 
updateErrorStatus(FlinkSessionJob, Context<FlinkSessionJob>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
 
updateFlinkResourceException(Throwable, R, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
 
updateForReconciliationError(AbstractFlinkResource<?, ?>, Throwable, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
updateIngressRules(ObjectMeta, FlinkDeploymentSpec, Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils
 
updateLastReconciledSavepointTriggerNonce(SavepointInfo, AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
updateLastSavepoint(Savepoint) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
Update last savepoint info and add the savepoint to the history if it isn't already the most recent savepoint.
updateMaxParallelism(JobVertexID, int) - Method in class org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
 
updateMetricHistory(SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
updateMetrics(AbstractFlinkResource<?, ?>, AutoScalerInfo, FlinkService, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.ScalingMetricCollector
 
updateReconciliationMetadata(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
updateStatusAfterClusterDeletion(FlinkDeploymentStatus) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Update status before deployment attempt of a new resource spec.
updateStatusForAlreadyUpgraded(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Updates status in cases where a previously successful deployment wasn't recorded for any reason.
updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
 
updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
Update status after successful deployment of a new resource spec.
updateStatusFromCache(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
Update the custom resource status based on the in-memory cached to ensure that any status updates that we made previously are always visible in the reconciliation loop.
updateStatusToDeployedIfAlreadyUpgraded(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information.
updateStatusToDeployedIfAlreadyUpgraded(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
 
updateStatusToDeployedIfAlreadyUpgraded(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
 
updateVertexList(List<JobVertexID>, Instant, Configuration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
UPGRADE - org.apache.flink.kubernetes.operator.api.diff.DiffType
Upgradable spec change.
UPGRADE - org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
Savepoint triggered during stateful upgrade.
UpgradeMode - Enum in org.apache.flink.kubernetes.operator.api.spec
Enum to control Flink job upgrade behavior.
UPGRADING - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
 
UPGRADING - org.apache.flink.kubernetes.operator.api.status.ReconciliationState
The spec is being upgraded.
URL - Static variable in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
 
UserLibMountDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators
Mount the Flink User Lib directory to enable Flink to pick up a Jars defined in pipeline.classpaths.
UserLibMountDecorator(StandaloneKubernetesJobManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.UserLibMountDecorator
 
Utils - Class in org.apache.flink.kubernetes.operator.docs.util
Contains various shared utility functions.
Utils() - Constructor for class org.apache.flink.kubernetes.operator.docs.util.Utils
 

V

v1_13 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
 
v1_14 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
 
v1_15 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
 
v1_16 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
 
v1_17 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
 
validate(HasMetadata, Operation) - Method in class org.apache.flink.kubernetes.operator.admission.FlinkValidator
 
VALIDATE_REQUEST_PATH - Static variable in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
 
validateDeployment(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator
 
validateDeployment(FlinkDeployment) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator
Validate and return optional error.
validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator
 
validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator
Validate and return optional error.
ValidationError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
 
ValidationException - Exception in org.apache.flink.kubernetes.operator.exception
Exception to signal validation failure.
ValidationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException
 
ValidationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException
 
ValidationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException
 
ValidatorUtils - Class in org.apache.flink.kubernetes.operator.utils
Validator utilities.
ValidatorUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ValidatorUtils
 
value() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Config
 
value() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff
 
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.JobState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.UpgradeMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.ReconciliationState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointFormatType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.SavepointStatus
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.JobState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.UpgradeMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.ReconciliationState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointFormatType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.MetricAggregator
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.autoscaler.metrics.ScalingMetric
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.config.Mode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.SavepointStatus
Returns an array containing the constants of this enum type, in the order they are declared.
verifyOtherPropsMatch(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
 
VERTEX_EXCLUDE_IDS - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
VERTEX_MAX_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
VERTEX_MIN_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
VERTEX_SCALING_HISTORY_AGE - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
VERTEX_SCALING_HISTORY_COUNT - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.config.AutoScalerOptions
 
VertexInfo - Class in org.apache.flink.kubernetes.operator.autoscaler.topology
Job vertex information.
VertexInfo() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.topology.VertexInfo
 

W

waitForClusterShutdown(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
 
waitForClusterShutdown(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
 
Warning - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
 
writeSpecWithMeta(AbstractFlinkSpec, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
Serializes the spec and custom meta information into a JSON string.
writeSpecWithMeta(AbstractFlinkSpec, ReconciliationMetadata) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
Serializes the spec and custom meta information into a JSON string.

Y

YAML_MAPPER - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.AutoScalerInfo
 
A B C D E F G H I J K L M N O P Q R S T U V W Y 
All Classes All Packages