Index (Flink Kubernetes: 1.8-SNAPSHOT API)

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

A

ABANDONED - org.apache.flink.kubernetes.operator.utils.SnapshotStatus: Manual snapshot is abandoned after defined retries.
AbstractFlinkDeploymentObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment: Base observer for session and application clusters.
AbstractFlinkDeploymentObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
AbstractFlinkResource<SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.api: Abstract base class Flink resources.
AbstractFlinkResource() - Constructor for class org.apache.flink.kubernetes.operator.api.AbstractFlinkResource
AbstractFlinkResourceObserver<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.observer: Base observer for all Flink resources.
AbstractFlinkResourceObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
AbstractFlinkResourceReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment: Base class for all Flink resource reconcilers.
AbstractFlinkResourceReconciler(EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
AbstractFlinkService - Class in org.apache.flink.kubernetes.operator.service: An abstract FlinkService containing some common implementations for the native and standalone Flink Services.
AbstractFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
AbstractFlinkSpec - Class in org.apache.flink.kubernetes.operator.api.spec: The common spec.
AbstractFlinkSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec
AbstractJobReconciler<CR extends AbstractFlinkResource<SPEC,STATUS>,SPEC extends AbstractFlinkSpec,STATUS extends CommonStatus<SPEC>> - Class in org.apache.flink.kubernetes.operator.reconciler.deployment: Reconciler responsible for handling the job lifecycle according to the desired and current states.
AbstractJobReconciler(EventRecorder, StatusRecorder<CR, STATUS>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
AbstractJobReconciler.AvailableUpgradeMode - Class in org.apache.flink.kubernetes.operator.reconciler.deployment: Object to capture available upgrade mode.
ACCUMULATED_BUSY_TIME - org.apache.flink.autoscaler.metrics.ScalingMetric
addOverride(String, String) - Method in class org.apache.flink.autoscaler.tuning.ConfigChanges
addOverride(ConfigOption<T>, T) - Method in class org.apache.flink.autoscaler.tuning.ConfigChanges
addRemoval(ConfigOption<?>) - Method in class org.apache.flink.autoscaler.tuning.ConfigChanges
addScalingRecord(Instant, ScalingRecord) - Method in class org.apache.flink.autoscaler.ScalingTracking
addStartupProbe(PodTemplateSpec) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
addToScalingHistoryAndStore(AutoScalerStateStore<KEY, Context>, Context, Instant, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
addToScalingHistoryAndStore(AutoScalerStateStore<KEY, Context>, Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>, Instant, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
AdmissionHandler - Class in org.apache.flink.kubernetes.operator.admission: Rest endpoint for validation requests.
AdmissionHandler(Validator<HasMetadata>, Mutator<HasMetadata>) - Constructor for class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
admissionResponseFromMutation(KubernetesResource, KubernetesResource) - Static method in class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator
allCanariesHealthy() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
allVerticesWithinUtilizationTarget(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>, Map<JobVertexID, ScalingSummary>) - Static method in class org.apache.flink.autoscaler.ScalingExecutor
API_GROUP - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
API_VERSION - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
append(String, DiffResult<?>) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
append(String, Object[], Object[], DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
append(String, Object, Object, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
append(String, S, S, BiFunction<S, S, Boolean>, DiffType) - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder
APPLICATION - org.apache.flink.kubernetes.operator.config.Mode
APPLICATION - org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
APPLICATION_MODE_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
ApplicationObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment: The observer of Mode.APPLICATION cluster.
ApplicationObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver
applicationProtocolNegotiator() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
ApplicationReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment: Reconciler Flink Application deployments.
ApplicationReconciler(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
applyFlinkConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyImage() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyImagePullPolicy() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyIngressDomain() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyJobManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyJobOrSessionSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyLogConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyMemoryScaling(MemorySize, MemoryBudget, JobAutoScalerContext<?>, Map<JobVertexID, ScalingSummary>, EvaluatedMetrics) - Static method in class org.apache.flink.autoscaler.tuning.MemoryScaling: Scales the amount of memory per TaskManager proportionally to the number of TaskManagers removed/added.
applyParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl: If there are any parallelism overrides by the JobAutoScaler apply them to the scalingRealizer.
applyPodTemplate() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyResourceToPodTemplate(PodTemplateSpec, Resource) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyServiceAccount() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyTaskManagerSpec() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
applyValidationErrorAndResetSpec(FlinkResourceContext<? extends AbstractFlinkResource<SPEC, ?>>, String) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: In case of validation errors we need to (temporarily) reset the old spec so that we can reconcile other outstanding changes, instead of simply blocking.
ArtifactFetcher - Interface in org.apache.flink.kubernetes.operator.artifact: The artifact fetcher.
artifactManager - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
ArtifactManager - Class in org.apache.flink.kubernetes.operator.artifact: Manage the user artifacts.
ArtifactManager(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.artifact.ArtifactManager
AuditUtils - Class in org.apache.flink.kubernetes.operator.listener: Responsible for logging resource event/status updates.
AuditUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.AuditUtils
autoscaler - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
AUTOSCALER_CONF_PREFIX - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
AUTOSCALER_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
AUTOSCALER_ERROR - Static variable in class org.apache.flink.autoscaler.JobAutoScalerImpl
AUTOSCALER_ERROR - Static variable in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor
AutoscalerError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
AutoScalerEvent - Class in org.apache.flink.autoscaler.jdbc.event: The Jdbc autoscaler event.
AutoScalerEvent() - Constructor for class org.apache.flink.autoscaler.jdbc.event.AutoScalerEvent
AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.event: Handler for autoscaler events.
AutoScalerEventHandler.Type - Enum in org.apache.flink.autoscaler.event: The type of the events.
AutoscalerEventHandlerFactory - Class in org.apache.flink.autoscaler.standalone: The factory of AutoScalerEventHandler.
AutoscalerEventHandlerFactory() - Constructor for class org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory
AutoscalerEventHandlerFactory.EventHandlerType - Enum in org.apache.flink.autoscaler.standalone: Out-of-box event handler type.
AutoscalerEventUtils - Class in org.apache.flink.autoscaler.event: The utils of AutoScalerEventHandler.
AutoscalerEventUtils() - Constructor for class org.apache.flink.autoscaler.event.AutoscalerEventUtils
AutoscalerFactory - Class in org.apache.flink.kubernetes.operator.autoscaler: The factory of JobAutoScaler.
AutoscalerFactory() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFactory
AutoscalerFlinkMetrics - Class in org.apache.flink.autoscaler.metrics: Autoscaler metrics for observability.
AutoscalerFlinkMetrics(MetricGroup) - Constructor for class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
AutoScalerOptions - Class in org.apache.flink.autoscaler.config: Config options related to the autoscaler module.
AutoScalerOptions() - Constructor for class org.apache.flink.autoscaler.config.AutoScalerOptions
AutoScalerSerDeModule - Class in org.apache.flink.autoscaler.utils: Jackson serializer module for JobVertexID.
AutoScalerSerDeModule() - Constructor for class org.apache.flink.autoscaler.utils.AutoScalerSerDeModule
AutoscalerStandaloneOptions - Class in org.apache.flink.autoscaler.standalone.config: Config options related to the autoscaler standalone module.
AutoscalerStandaloneOptions() - Constructor for class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
AutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.state: The state store is responsible for storing all state during scaling.
AutoscalerStateStoreFactory - Class in org.apache.flink.autoscaler.standalone: The factory of AutoScalerStateStore.
AutoscalerStateStoreFactory() - Constructor for class org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory
AutoscalerStateStoreFactory.StateStoreType - Enum in org.apache.flink.autoscaler.standalone: Out-of-box state store type.
AutoScalerUtils - Class in org.apache.flink.autoscaler.utils: AutoScaler utilities.
AutoScalerUtils() - Constructor for class org.apache.flink.autoscaler.utils.AutoScalerUtils
autoscaling - package autoscaling
AutoscalingExample - Class in autoscaling: Autoscaling Example.
AutoscalingExample() - Constructor for class autoscaling.AutoscalingExample
AvailableUpgradeMode() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.AvailableUpgradeMode
AVERAGE - Static variable in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
avg(double) - Static method in class org.apache.flink.autoscaler.metrics.EvaluatedScalingMetric
AVG - org.apache.flink.autoscaler.metrics.MetricAggregator

B

BACKLOG_PROCESSING_LAG_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
BACKPRESSURE_TIME_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric
BROADCAST - org.apache.flink.autoscaler.topology.ShipStrategy
budget(long) - Method in class org.apache.flink.autoscaler.tuning.MemoryBudget
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.autoscaler.config.AutoScalerOptions
BUSY_TIME_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric

C

calculateClusterCpuUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
calculateClusterMemoryUsage(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
CalendarUtils - Class in org.apache.flink.autoscaler.utils: Calendar utilities.
CalendarUtils() - Constructor for class org.apache.flink.autoscaler.utils.CalendarUtils
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
cancelPending() - Method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceView
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.autoscaler.metrics.ScalingMetric: Target processing rate of operators as derived from backlog (records/sec).
CATCH_UP_DURATION - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
changeLastStateIfCheckpointTooOld(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler
channelRead0(ChannelHandlerContext, HttpRequest) - Method in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
checkAndUpdateStableSpec(CommonStatus<?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Checks the status and if the corresponding Flink job/application is in stable running state, it updates the last stable spec.
checkHealth(ResourceID, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
checkIfAlreadyUpgraded(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver: Checks a resource that is currently in the UPGRADING state whether it was already deployed but we simply miss the status information.
checkIfAlreadyUpgraded(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
checkIfAlreadyUpgraded(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
checkObjectCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
Checkpoint - Class in org.apache.flink.kubernetes.operator.api.status: Represents information about a finished checkpoint.
Checkpoint(long, SnapshotTriggerType, CheckpointType, Long) - Constructor for class org.apache.flink.kubernetes.operator.api.status.Checkpoint
CHECKPOINT - org.apache.flink.kubernetes.operator.reconciler.SnapshotType
CheckpointError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
CheckpointFetchResult - Class in org.apache.flink.kubernetes.operator.observer: Result of a fetch checkpoint operation.
CheckpointFetchResult() - Constructor for class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult
CheckpointHistoryWrapper - Class in org.apache.flink.kubernetes.operator.service: Custom Response for handling checkpoint history in a multi-version compatible way.
CheckpointHistoryWrapper() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper
CheckpointHistoryWrapper.CompletedCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service: Information about the latest completed checkpoint/savepoint.
CheckpointHistoryWrapper.PendingCheckpointInfo - Class in org.apache.flink.kubernetes.operator.service: Information about the currently pending checkpoint/savepoint.
CheckpointInfo - Class in org.apache.flink.kubernetes.operator.api.status: Stores checkpoint-related information.
CheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
checkpointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils
CheckpointType - Enum in org.apache.flink.kubernetes.operator.api.status: Checkpoint format type.
checkStringTypeCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
checkTypeCompatibility(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
cipherSuites() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
cleanup(CR) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
cleanup(KEY) - Method in interface org.apache.flink.autoscaler.JobAutoScaler: Called when the job is deleted.
cleanup(KEY) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl
cleanup(KEY) - Method in class org.apache.flink.autoscaler.NoopJobAutoscaler
cleanup(KEY) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
cleanup(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
cleanup(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
cleanup(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
cleanup(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler: This is called when receiving the delete event of custom resource.
Cleanup - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
cleanupAfterFailedJob(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler: Removes a failed job.
cleanupAfterFailedJob(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
cleanupAfterFailedJob(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
cleanupDoneFor(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
CleanupFailed - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
cleanupInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler: Shut down and clean up all Flink job/cluster resources.
cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
cleanupInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
cleanupInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
cleanupTmpFiles(Configuration) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
clear() - Method in class org.apache.flink.autoscaler.jdbc.state.JobStateView
clearAll(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
clearAll(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore: Removes all data from this context.
clearAll(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
clearAll(String) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
clearAll(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
clearAll(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
clearErrorsIfDeploymentIsHealthy(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
clearLastReconciledSpecIfFirstDeploy(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Clear last reconciled spec if that corresponds to the first deployment.
clock - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
clone(T) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
clone(T) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
close() - Method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor
CLUSTER_MODE - Static variable in class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
ClusterHealthEvaluator - Class in org.apache.flink.kubernetes.operator.observer: Evaluates whether the cluster is healthy.
ClusterHealthEvaluator(Clock) - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
ClusterHealthInfo - Class in org.apache.flink.kubernetes.operator.health: Represents information about job health.
ClusterHealthInfo() - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
ClusterHealthInfo(Clock) - Constructor for class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
ClusterHealthObserver - Class in org.apache.flink.kubernetes.operator.observer: An observer to observe the cluster health.
ClusterHealthObserver() - Constructor for class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver
ClusterResourceManager - Class in org.apache.flink.kubernetes.operator.resources: A cluster resource manager which provides a view over the allocatable resources within a Kubernetes cluster and allows to simulate scheduling pods with a defined number of required resources.
ClusterResourceManager(Duration, KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.resources.ClusterResourceManager
ClusterResourceView - Class in org.apache.flink.kubernetes.operator.resources: A view on Kubernetes cluster resources by nodes and their cpu/memory.
ClusterResourceView() - Constructor for class org.apache.flink.kubernetes.operator.resources.ClusterResourceView
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 - org.apache.flink.autoscaler.jdbc.state.StateType
COLLECTED_METRICS_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
CollectedMetricHistory - Class in org.apache.flink.autoscaler.metrics: Topology and collected metric history.
CollectedMetricHistory() - Constructor for class org.apache.flink.autoscaler.metrics.CollectedMetricHistory
CollectedMetrics - Class in org.apache.flink.autoscaler.metrics: Collected scaling metrics.
CollectedMetrics() - Constructor for class org.apache.flink.autoscaler.metrics.CollectedMetrics
commit() - Method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceView
commitPending() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
commitPending() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesResource
CommonStatus<SPEC extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.status: Last observed common status of the Flink deployment/Flink SessionJob.
CommonStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.CommonStatus
CompatibilityError(String) - Constructor for exception org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.CompatibilityError
completed() - Static method in class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult
completed(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
CompletedCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.CompletedCheckpointInfo
computeBusyTimeAvg(Configuration, SortedMap<Instant, CollectedMetrics>, JobVertexID, int) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator: Compute the average busy time for the given vertex for the current metric window.
computeDataRateMetrics(JobVertexID, Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>, JobTopology, Configuration, Supplier<Double>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics
computeEdgeDataRate(JobTopology, SortedMap<Instant, CollectedMetrics>, JobVertexID, JobVertexID) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator: Compute how many records flow between two job vertices in the pipeline.
computeEdgeOutputRatio(JobVertexID, JobVertexID, JobTopology, SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator: Compute the In/Out ratio between the (from, to) vertices.
computeGlobalMetrics(Map<FlinkMetric, Metric>, Map<FlinkMetric, AggregatedMetric>, Configuration) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics
computeLagMetrics(Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics
computeLoadMetrics(JobVertexID, Map<FlinkMetric, AggregatedMetric>, Map<ScalingMetric, Double>, IOMetrics, Configuration) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics
computeNewParallelisms(Map<JobVertexID, ScalingSummary>, Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Static method in class org.apache.flink.autoscaler.utils.ResourceCheckUtils
computeObservedTprWithBackpressure(double, double) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics
computeProcessingRateThresholds(Map<ScalingMetric, EvaluatedScalingMetric>, Configuration, boolean, Duration) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator
computeScaleTargetParallelism(Context, JobVertexID, Collection<ShipStrategy>, Map<ScalingMetric, EvaluatedScalingMetric>, SortedMap<Instant, ScalingSummary>, Duration) - Method in class org.apache.flink.autoscaler.JobVertexScaler
computeTrueProcessingRate(double, double, SortedMap<Instant, CollectedMetrics>, JobVertexID, Configuration) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator: Compute the true processing rate for the given vertex for the current metric window.
CONFIG_OVERRIDES - org.apache.flink.autoscaler.jdbc.state.StateType
CONFIG_OVERRIDES_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
ConfigChanges - Class in org.apache.flink.autoscaler.tuning: Holds the configuration overrides and removals for a Flink Configuration.
ConfigChanges() - Constructor for class org.apache.flink.autoscaler.tuning.ConfigChanges
configManager - Variable in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
ConfigMapStore - Class in org.apache.flink.kubernetes.operator.autoscaler.state: The ConfigMapStore persists state in Kubernetes ConfigMaps.
ConfigMapStore(KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
ConfigOptionsDocGenerator - Class in org.apache.flink.kubernetes.operator.docs.configuration: Class used for generating code based documentation of configuration parameters.
ConfigOptionUtils - Class in org.apache.flink.kubernetes.operator.utils: ConfigOption utilities.
ConfigOptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils
CONTROL_LOOP_INTERVAL - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
CONTROL_LOOP_PARALLELISM - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
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, ClusterResourceManager) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFactory
create(Configuration) - Static method in class org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory
create(Configuration) - Static method in class org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory
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
createData(String, List<StateType>, Map<StateType, String>) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateInteractor
createEvent(String, String, AutoScalerEventHandler.Type, String, String) - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
createFlinkDeploymentMetricManager(Configuration, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
createFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
createFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
createFlinkSessionJobMetricManager(Configuration, KubernetesOperatorMetricGroup) - Static method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
createFromIdentifier(String) - Static method in enum org.apache.flink.autoscaler.jdbc.state.StateType
createHistogram(FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
createIfNotExists(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils
createMetricConfig(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
createNamespacedKubeClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext: Generate the config that is currently deployed for the resource spec.
createObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
createOperator() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
createOrUpdateEventWithInterval(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String, Duration) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils
createOrUpdateEventWithLabels(KubernetesClient, HasMetadata, EventRecorder.Type, String, String, EventRecorder.Component, Consumer<Event>, String, Duration, Predicate<Map<String, String>>, Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils
createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
createQueryServiceMetricInfo(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
createResourceGroup(Configuration, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
createResourceMetricGroup(KubernetesOperatorMetricGroup, FlinkConfigManager, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
createResourceNamespaceGroup(Configuration, Class<? extends AbstractFlinkResource>, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
createTaskManagerDeployment(Deployment) - Method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
createTaskManagerDeployment(Deployment) - Method in interface org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient
current() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion: Returns the current version.
CURRENT - Static variable in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
CUSTOM - org.apache.flink.autoscaler.topology.ShipStrategy
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

DateTimeUtils - Class in org.apache.flink.autoscaler.utils: Date and time related utilities.
DateTimeUtils() - Constructor for class org.apache.flink.autoscaler.utils.DateTimeUtils
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
DefaultFlinkMutator - Class in org.apache.flink.kubernetes.operator.mutator: Default Flink Mutator.
DefaultFlinkMutator() - Constructor for class org.apache.flink.kubernetes.operator.mutator.DefaultFlinkMutator
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
deleteBlocking(String, Callable<Waitable>, Duration) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService: Generic blocking delete operation implementation for triggering and waiting for removal of the selected resources.
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(String, String, Configuration, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService: Delete Flink kubernetes cluster by deleting the kubernetes resources directly.
deleteClusterInternal(String, String, Configuration, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
deleteClusterInternal(String, String, Configuration, DeletionPropagation) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
deleteData(String, List<StateType>) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateInteractor
deleteDeploymentBlocking(String, Resource<Deployment>, DeletionPropagation, Duration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService: Wait until Deployment is removed, return remaining timeout.
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
deploySessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
deploySessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
deploySessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
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.
discoverMutators(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.utils.MutatorUtils: discovers mutators.
discoverValidators(FlinkConfigManager) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils
disposeSavepoint(String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
disposeSavepoint(String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
DRAIN_ON_SAVEPOINT_DELETION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions

E

Edge - Class in org.apache.flink.autoscaler.metrics: Collected scaling metrics.
Edge() - Constructor for class org.apache.flink.autoscaler.metrics.Edge
ENV_CONF_OVERRIDE_DIR - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
ENV_HOSTNAME - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
ENV_KUBERNETES_SERVICE_HOST - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
ENV_OPERATOR_KEYSTORE_PASSWORD - Static variable in class org.apache.flink.kubernetes.operator.utils.EnvUtils
ENV_OPERATOR_KEYSTORE_PATH - 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_OPERATOR_TRUSTSTORE_PATH - 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.CheckpointFetchResult
error(String) - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
ERROR - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus: Deployment in terminal error, requires spec change for reconciliation to continue.
escapeCharacters(String) - Static method in class org.apache.flink.kubernetes.operator.docs.util.Utils
estimateNumTaskSlotsAfterRescale(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>, Map<JobVertexID, ScalingSummary>, int) - Static method in class org.apache.flink.autoscaler.utils.ResourceCheckUtils
evaluate(Configuration, Map<String, String>, ClusterHealthInfo) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
evaluate(Configuration, CollectedMetricHistory, Duration) - Method in class org.apache.flink.autoscaler.ScalingMetricEvaluator
EvaluatedMetrics - Class in org.apache.flink.autoscaler.metrics: Collected scaling metrics.
EvaluatedMetrics() - Constructor for class org.apache.flink.autoscaler.metrics.EvaluatedMetrics
EvaluatedScalingMetric - Class in org.apache.flink.autoscaler.metrics: Evaluated scaling metric.
EvaluatedScalingMetric(double, double) - Constructor for class org.apache.flink.autoscaler.metrics.EvaluatedScalingMetric
evaluateGlobalMetrics(SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator
EVENT_HANDLER_TYPE - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
eventRecorder - Variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
eventRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
EventRecorder - Class in org.apache.flink.kubernetes.operator.utils: Helper class for creating Kubernetes events for Flink resources.
EventRecorder(BiConsumer<AbstractFlinkResource<?, ?>, Event>) - Constructor for class org.apache.flink.kubernetes.operator.utils.EventRecorder
EventRecorder.Component - Enum in org.apache.flink.kubernetes.operator.utils: The component of events.
EventRecorder.Reason - Enum in org.apache.flink.kubernetes.operator.utils: The reason codes of events.
EventRecorder.Type - Enum in org.apache.flink.kubernetes.operator.utils: The type of the events.
EventSourceUtils - Class in org.apache.flink.kubernetes.operator.utils: Utility class to locate secondary resources.
EventSourceUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
EventUtils - Class in org.apache.flink.kubernetes.operator.utils: The util to generate an event for the target resource.
EventUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.EventUtils
EXCLUDED_PERIODS - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
excludeVertexFromScaling(Configuration, JobVertexID) - Static method in class org.apache.flink.autoscaler.utils.AutoScalerUtils: Temporarily exclude vertex from scaling for this run.
excludeVerticesFromScaling(Configuration, Collection<JobVertexID>) - Static method in class org.apache.flink.autoscaler.utils.AutoScalerUtils
executorService - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
EXPECTED_PROCESSING_RATE - org.apache.flink.autoscaler.metrics.ScalingMetric: Expected true processing rate after scale up.

F

Fabric8FlinkStandaloneKubeClient - Class in org.apache.flink.kubernetes.operator.kubeclient: The Implementation of FlinkStandaloneKubeClient.
Fabric8FlinkStandaloneKubeClient(Configuration, NamespacedKubernetesClient, ExecutorService) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
FAILED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
failedReconciliation(ResourceID, Exception, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
fetch() - Method in class org.apache.flink.autoscaler.standalone.flinkcluster.FlinkClusterJobListFetcher
fetch() - Method in interface org.apache.flink.autoscaler.standalone.JobListFetcher
fetch(String, Configuration, File) - Method in interface org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher: Fetch the resource from the uri to the targetDir.
fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
fetch(String, Configuration, File) - Method in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
fetch(String, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.artifact.ArtifactManager
fetchCheckpointInfo(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
fetchCheckpointInfo(String, String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
FETCHER_FLINK_CLUSTER_HOST - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
FETCHER_FLINK_CLUSTER_PORT - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
fetchSavepointInfo(String, String, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
fetchSavepointInfo(String, String, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
FIELD_NAME_ACC_BACK_PRESSURE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_ACC_BUSY - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_ACC_IDLE - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_BYTES_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_BYTES_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_FLINK_REVISION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration
FIELD_NAME_FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration
FIELD_NAME_FORMAT_TYPE - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
FIELD_NAME_RECORDS_READ - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_RECORDS_WRITTEN - Static variable in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
FIELD_NAME_TARGET_DIRECTORY - Static variable in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
FIELD_NAME_TOTAL_CPU - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
FIELD_NAME_TOTAL_MEMORY - Static variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
FileSystemBasedArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact: Leverage the flink filesystem plugin to fetch the artifact.
FileSystemBasedArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
FileSystemWatchService - Class in org.apache.flink.kubernetes.operator.fs: Service which is able to watch local filesystem directories.
FileSystemWatchService(String) - Constructor for class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
filterTargetJob(JobStatus, List<JobStatusMessage>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver: Filter the target job status message by the job list from the cluster.
findAll(Collection<String>) - Method in enum org.apache.flink.autoscaler.metrics.FlinkMetric
findAny(Collection<String>) - Method in enum org.apache.flink.autoscaler.metrics.FlinkMetric
findExistingEvent(KubernetesClient, HasMetadata, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EventUtils
FINISHED_METRICS - Static variable in enum org.apache.flink.autoscaler.metrics.FlinkMetric
FINISHED_METRICS - Static variable in class org.apache.flink.autoscaler.topology.IOMetrics
finishedReconciliation(ResourceID, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
FLINK_CLIENT_TIMEOUT - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
FLINK_MEMORY_UTILS - Static variable in class org.apache.flink.autoscaler.tuning.MemoryTuning
FLINK_VERSION - Static variable in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
FLINK_VERSION_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
FlinkClusterJobListFetcher - Class in org.apache.flink.autoscaler.standalone.flinkcluster: Fetch JobAutoScalerContext based on flink cluster.
FlinkClusterJobListFetcher(FunctionWithException<Configuration, RestClusterClient<String>, Exception>, Duration) - Constructor for class org.apache.flink.autoscaler.standalone.flinkcluster.FlinkClusterJobListFetcher
FlinkConfigBuilder - Class in org.apache.flink.kubernetes.operator.config: Builder to get effective flink config from FlinkDeployment.
FlinkConfigBuilder(String, String, FlinkDeploymentSpec, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
FlinkConfigBuilder(FlinkDeployment, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
FlinkConfigManager - Class in org.apache.flink.kubernetes.operator.config: Configuration manager for the Flink operator.
FlinkConfigManager(Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
FlinkConfigManager(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
FlinkConfigManager(Configuration, Consumer<Set<String>>) - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
FlinkDeployment - Class in org.apache.flink.kubernetes.operator.api: Custom resource definition that represents both Application and Session deployments.
FlinkDeployment() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkDeployment
FlinkDeploymentContext - Class in org.apache.flink.kubernetes.operator.controller: Context for reconciling a Flink resource.
FlinkDeploymentContext(FlinkDeployment, Context<?>, KubernetesResourceMetricGroup, FlinkConfigManager, Function<FlinkResourceContext<?>, FlinkService>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
FlinkDeploymentController - Class in org.apache.flink.kubernetes.operator.controller: Controller that runs the main reconcile loop for Flink deployments.
FlinkDeploymentController(Set<FlinkResourceValidator>, FlinkResourceContextFactory, ReconcilerFactory, FlinkDeploymentObserverFactory, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, EventRecorder, CanaryResourceManager<FlinkDeployment>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
FlinkDeploymentList - Class in org.apache.flink.kubernetes.operator.api: Multiple Flink deployments.
FlinkDeploymentList() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkDeploymentList
FlinkDeploymentMetrics - Class in org.apache.flink.kubernetes.operator.metrics: FlinkDeployment metrics.
FlinkDeploymentMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
FlinkDeploymentObserverFactory - Class in org.apache.flink.kubernetes.operator.observer.deployment: The factory to create the observer based on the FlinkDeployment mode.
FlinkDeploymentObserverFactory(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory
FlinkDeploymentReconciliationStatus - Class in org.apache.flink.kubernetes.operator.api.status: Status of the last reconcile step for the flink deployment.
FlinkDeploymentReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentReconciliationStatus
FlinkDeploymentSpec - Class in org.apache.flink.kubernetes.operator.api.spec: Spec that describes a Flink application or session cluster deployment.
FlinkDeploymentSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec
FlinkDeploymentStatus - Class in org.apache.flink.kubernetes.operator.api.status: Last observed status of the Flink deployment.
FlinkDeploymentStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus
FlinkMetric - Enum in org.apache.flink.autoscaler.metrics: Enum representing the collected Flink metrics for autoscaling.
FlinkMutator - Class in org.apache.flink.kubernetes.operator.admission.mutator: The default mutator.
FlinkMutator(Set<FlinkResourceMutator>, InformerManager) - Constructor for class org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator
FlinkOperator - Class in org.apache.flink.kubernetes.operator: Main Class for Flink native k8s operator.
FlinkOperator(Configuration) - Constructor for class org.apache.flink.kubernetes.operator.FlinkOperator
FlinkOperatorConfiguration - Class in org.apache.flink.kubernetes.operator.config: Configuration class for operator.
FlinkOperatorConfiguration() - Constructor for class org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration
FlinkOperatorWebhook - Class in org.apache.flink.kubernetes.operator.admission: Main Class for Flink native k8s operator.
FlinkOperatorWebhook() - Constructor for class org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook
FlinkResourceContext<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.controller: Context for reconciling a Flink resource.
FlinkResourceContext() - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
FlinkResourceContextFactory - Class in org.apache.flink.kubernetes.operator.service: Factory for creating the FlinkResourceContext.
FlinkResourceContextFactory(FlinkConfigManager, KubernetesOperatorMetricGroup, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
FlinkResourceException - Class in org.apache.flink.kubernetes.operator.exception: Exception to display as JSON in CRD.
FlinkResourceException() - Constructor for class org.apache.flink.kubernetes.operator.exception.FlinkResourceException
FlinkResourceExceptionUtils - Class in org.apache.flink.kubernetes.operator.utils: Flink Resource Exception utilities.
FlinkResourceExceptionUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
FlinkResourceListener - Interface in org.apache.flink.kubernetes.operator.api.listener: Listener interface for Flink resource related events and status changes.
FlinkResourceListener.ResourceContext<R extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.api.listener: Base for Resource Event and StatusUpdate contexts.
FlinkResourceListener.ResourceEventContext<R extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.api.listener: Context for Resource Event listener methods.
FlinkResourceListener.StatusUpdateContext<R extends AbstractFlinkResource<?,S>,S extends CommonStatus<?>> - Interface in org.apache.flink.kubernetes.operator.api.listener: Context for Status listener methods.
FlinkResourceMutator - Interface in org.apache.flink.kubernetes.operator.mutator: Mutator for Flink Resources.
FlinkResourceUtils - Class in org.apache.flink.kubernetes.operator.api.utils: Utilities for Flink K8S resource.
FlinkResourceUtils() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
FlinkResourceValidator - Interface in org.apache.flink.kubernetes.operator.validation: Validator for different resources.
FlinkService - Interface in org.apache.flink.kubernetes.operator.service: Service for submitting and interacting with Flink clusters and jobs.
FlinkSessionJob - Class in org.apache.flink.kubernetes.operator.api: Custom resource definition that represents a flink session job.
FlinkSessionJob() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkSessionJob
FlinkSessionJobContext - Class in org.apache.flink.kubernetes.operator.controller: Context for reconciling a Flink resource.
FlinkSessionJobContext(FlinkSessionJob, Context<?>, KubernetesResourceMetricGroup, FlinkConfigManager, Function<FlinkResourceContext<?>, FlinkService>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
FlinkSessionJobController - Class in org.apache.flink.kubernetes.operator.controller: Controller that runs the main reconcile loop for FlinkSessionJob.
FlinkSessionJobController(Set<FlinkResourceValidator>, FlinkResourceContextFactory, Reconciler<FlinkSessionJob>, Observer<FlinkSessionJob>, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, EventRecorder, CanaryResourceManager<FlinkSessionJob>) - Constructor for class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
FlinkSessionJobList - Class in org.apache.flink.kubernetes.operator.api: Multiple Flink session jobs.
FlinkSessionJobList() - Constructor for class org.apache.flink.kubernetes.operator.api.FlinkSessionJobList
FlinkSessionJobMetrics - Class in org.apache.flink.kubernetes.operator.metrics: FlinkSessionJob metrics.
FlinkSessionJobMetrics(KubernetesOperatorMetricGroup, Configuration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
FlinkSessionJobObserver - Class in org.apache.flink.kubernetes.operator.observer.sessionjob: The observer of FlinkSessionJob.
FlinkSessionJobObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
FlinkSessionJobReconciliationStatus - Class in org.apache.flink.kubernetes.operator.api.status: Status of the last reconcile step for the flink sessionjob.
FlinkSessionJobReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobReconciliationStatus
FlinkSessionJobSpec - Class in org.apache.flink.kubernetes.operator.api.spec: Spec that describes a Flink session job.
FlinkSessionJobSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec
FlinkSessionJobStatus - Class in org.apache.flink.kubernetes.operator.api.status: Last observed status of the Flink Session job.
FlinkSessionJobStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus
FlinkStandaloneKubeClient - Interface in org.apache.flink.kubernetes.operator.kubeclient: Extension of the FlinkKubeClient that is used for Flink standalone deployments.
FlinkUtils - Class in org.apache.flink.kubernetes.operator.utils: Flink Utility methods used by the operator.
FlinkUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.FlinkUtils
FlinkValidator - Class in org.apache.flink.kubernetes.operator.admission: Validator for FlinkDeployment creation and updates.
FlinkValidator(Set<FlinkResourceValidator>, InformerManager) - Constructor for class org.apache.flink.kubernetes.operator.admission.FlinkValidator
FlinkVersion - Enum in org.apache.flink.kubernetes.operator.api.spec: Enumeration for supported Flink versions.
flinkVersionChanged(SPEC, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
flush() - Method in class org.apache.flink.autoscaler.jdbc.state.JobStateView
flush(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
flush(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore: Flushing is needed because we do not persist data for all store methods until this method is called.
flush(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
flush(String) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
flush(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
flush(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
format(Event) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils
formatErrorMessage(Long) - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
formatErrorMessage(Long) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
formatErrorMessage(Long) - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
formatScope(String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
formatScope(String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
formatScope(String, String, String, String, String, String) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
FORWARD - org.apache.flink.autoscaler.topology.ShipStrategy
from - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
from(Collection<DiffType>) - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType: Aggregate a collection of DiffTypes into the type that minimally subsumes all the diffs.
from(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata
from(IOMetricsInfo) - Static method in class org.apache.flink.autoscaler.topology.IOMetrics
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>, Map<JobVertexID, IOMetrics>, Set<JobVertexID>) - Static method in class org.apache.flink.autoscaler.topology.JobTopology
fromRuntimeInfo(RuntimeInfo) - Static method in class org.apache.flink.kubernetes.operator.health.InformerHealthSummary
FULL - org.apache.flink.kubernetes.operator.api.status.CheckpointType

G

GC_PRESSURE - org.apache.flink.autoscaler.metrics.ScalingMetric: Maximum GC pressure across taskmanagers.
GC_PRESSURE_MESSAGE - Static variable in class org.apache.flink.autoscaler.ScalingExecutor
GC_PRESSURE_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
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
get(String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils: Get the value provided by environments.
get(StateType) - Method in class org.apache.flink.autoscaler.jdbc.state.JobStateView
get(JobVertexID) - Method in class org.apache.flink.autoscaler.topology.JobTopology
get(AggregatedMetric) - Method in enum org.apache.flink.autoscaler.metrics.MetricAggregator
getAccumulatedBackpressured() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getAccumulatedBusy() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getAccumulatedIdle() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getAllowNonRestoredState() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
getAnnotations() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getAvailableUpgradeMode(FlinkResourceContext<CR>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
getAvailableUpgradeMode(FlinkResourceContext<FlinkDeployment>, Configuration) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
getAvailableVertexMetricNames() - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getAverage(ScalingMetric, JobVertexID, SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator
getAverage(ScalingMetric, JobVertexID, SortedMap<Instant, CollectedMetrics>, int) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator
getBytesRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getBytesWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getCache() - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
getCache() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
getCheckpointInfo(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getCheckpointInfo(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getCheckpointInfo(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
getClearedStatesAfterTransition(ResourceLifecycleState) - Method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
getClusterClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getClusterClient(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getClusterDescription() - Method in class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor
getClusterInfo(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getClusterInfo(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getCollectedMetrics(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
getCollectedMetrics(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
getCollectedMetrics(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
getCollectedMetrics(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
getCommonLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
getCommonLabels(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
getConfigChanges(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
getConfigChanges(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
getConfigChanges(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
getConfigChanges(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
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
getCurrentInstant() - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
getCurrentState() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
getDataReadOnly() - Method in class org.apache.flink.autoscaler.jdbc.state.JobStateView
getDefaultConfig() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
getDefaultConfig(String, FlinkVersion) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager: Get the base configuration for the given namespace and flink version combination.
getDeployConfig(ObjectMeta, FlinkDeploymentSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager: Get deployment configuration that will be passed to the Flink Cluster clients during cluster submission.
getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext: Get Flink configuration object for deploying the given spec using AbstractFlinkResourceReconciler.deploy(org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>, SPEC, org.apache.flink.configuration.Configuration, java.util.Optional<java.lang.String>, boolean).
getDeployConfig(AbstractFlinkSpec) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
getDeployedSpec(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
getDeploymentInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
getDeploymentMode() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
getDeploymentMode() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
getDeploymentMode() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
getDeploymentMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
getDeploymentMode(FlinkDeploymentSpec) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
getDescription() - Method in enum org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory.EventHandlerType
getDescription() - Method in enum org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory.StateStoreType
getDescription() - Method in enum org.apache.flink.kubernetes.operator.api.status.CheckpointType
getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getDescription() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getEffectiveStatus(JobDetails) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getEnvironments() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getEvent() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext
getFlinkDepInformer(String) - Method in class org.apache.flink.kubernetes.operator.admission.informer.InformerManager
getFlinkDeploymentInformerEventSource(EventSourceContext<FlinkSessionJob>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
getFlinkResource() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
getFlinkService() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext: Get the FlinkService implementation for the current resource.
getFlinkService(FlinkResourceContext<?>) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
getFlinkVersion() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
getFlinkVersion() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
getFlinkVersion() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
getFormatType() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
getFree() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesResource
getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
getGroupName(CharacterFilter) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
getHistories() - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getHttpMethod() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getIdentifier() - Method in enum org.apache.flink.autoscaler.jdbc.state.StateType
getIngressUrl(String, String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils
getInProgressCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper
getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getInstance() - Static method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
getJmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
getJmPodList(FlinkDeployment, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getJmPodList(FlinkDeployment, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getJobAutoScalerContext() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
getJobDetailsInfo(JobAutoScalerContext<KEY>, Duration) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getJobManagerDeploymentName(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
getJobManagerSelectors(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
getJobRunningTs(JobDetailsInfo) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getJobSpec(AbstractFlinkResource<? extends AbstractFlinkSpec, ? extends CommonStatus<?>>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
getJobSpecArgs() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
getJobStatus(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
getJobTopology(Context, AutoScalerStateStore<KEY, Context>, JobDetailsInfo) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getJobTopology(JobDetailsInfo) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext
getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext: Get KubernetesClient available from JOSDK Context.
getKubernetesClient() - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getKubernetesClient() - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getKubernetesClient(FlinkOperatorConfiguration, MetricGroup) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
getKubernetesClient(FlinkOperatorConfiguration, MetricGroup, Config) - Static method in class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
getLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
getLabels() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getLastCheckpoint(JobID, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getLastCheckpoint(JobID, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getLastPeriodicTriggerTimestamp() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
getLastPeriodicTriggerTimestamp() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
getLastPeriodicTriggerTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getLastSnapshot() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
getLastSnapshot() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
getLastSnapshot() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getLastSnapshotStatus(AbstractFlinkResource<?, ?>, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils
getLastTriggerNonce() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
getLastTriggerNonce() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
getLastTriggerNonce() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getLastTriggerType() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
getLastTriggerType() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
getLastTriggerType() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
getLatestCompletedCheckpoint() - Method in class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper
getLatestScalingRecordEntry() - Method in class org.apache.flink.autoscaler.ScalingTracking
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
getMaxRestartTimeOrDefault(Configuration) - Method in class org.apache.flink.autoscaler.ScalingTracking: Retrieves the maximum restart time based on the provided configuration and scaling records.
getMemoryLimitFactor() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getMetricGroup() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
getMetrics(Configuration, String, List<String>) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getMetrics(Configuration, String, List<String>) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
getMetricWindowSize(Configuration) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
getMode(FlinkDeployment) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode: Return the mode of the given FlinkDeployment for Observer and Reconciler.
getName() - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
getNewStatus() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext
getNodeSelector() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getNumBalancedCount() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
getNumberOfActiveCanaries() - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
getNumDiffs() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult
getNumErrorsCount() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
getNumScalingsCount() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
getNumTaskManagers(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
getNumTaskManagers(Configuration, int) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
getObserveConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext: Get the config that is currently deployed for the resource spec.
getObserveConfig(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager: Get the observe configuration that can be used to interact with already submitted clusters through the Flink rest clients.
getOperator() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
getOperatorConfig() - Method in class org.apache.flink.kubernetes.operator.controller.FlinkResourceContext
getOperatorConfiguration() - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
getOperatorConfiguration(String, FlinkVersion) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager: Get the operator configuration for the given namespace and flink version combination.
getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory
getOrCreate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory
getOrDefault(String, String) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils: Get the value or default value provided by environments.
getOwnerReference() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getParallelismHashCode(Map<JobVertexID, ScalingSummary>) - Static method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
getParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
getParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl
getParallelismOverrides(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
getParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
getParallelismOverrides(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
getPodTemplateFilePath() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getPreviousStatus() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext
getRate() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
getRate(ScalingMetric, JobVertexID, SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator: Compute per second rate for the given accumulated metric over the metric window.
getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
getReason() - Method in exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException
getReconciledJobSpec(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
getReconciledJobState(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
getReconciliationStatus() - Method in class org.apache.flink.kubernetes.operator.api.status.CommonStatus: Current reconciliation status of this resource.
getRecordsRead() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getRecordsWritten() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
getRegisteredMetrics() - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
getRemaining() - Method in class org.apache.flink.autoscaler.tuning.MemoryBudget
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.
getResource() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext
getResourceContext(CR, Context) - Method in class org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getResponseClass() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getResponseStatusCode() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getRestClient(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getRestClusterClient() - Method in class org.apache.flink.autoscaler.JobAutoScalerContext
getRPCPort() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getSavepointInfo(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
getSavepointPath() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
getScalingHistory(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
getScalingHistory(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
getScalingHistory(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
getScalingHistory(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
getScalingTracking(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
getScalingTracking(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
getScalingTracking(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
getScalingTracking(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
getSelectors() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
getSelectors() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getSerializedState(String, StateType) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
getSerializedState(KubernetesJobAutoScalerContext, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
getServiceAccount() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getSessionJobConfig(FlinkDeployment, FlinkSessionJobSpec) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager: Get configuration for interacting with session jobs.
getSessionJobInformerEventSource(EventSourceContext<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.utils.EventSourceUtils
getSocketAddress(RestClusterClient<String>) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
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, Duration) - Static method in class org.apache.flink.autoscaler.utils.AutoScalerUtils
getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getTargetRestEndpointURL() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getTaskManagerCpu() - Method in class org.apache.flink.autoscaler.JobAutoScalerContext: Retrieve the currently configured TaskManager CPU.
getTaskManagerCpu() - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext
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
getTaskManagerMemory() - Method in class org.apache.flink.autoscaler.JobAutoScalerContext: Retrieve the currently configured TaskManager memory.
getTaskManagerMemoryMB() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getTaskManagerSelectors(String) - Static method in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
getTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
getTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext
getTimeStamp() - Method in interface org.apache.flink.kubernetes.operator.api.status.Snapshot
getTmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
getTmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
getTmPodList(String, String) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
getTolerations() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
getTotalMemory(Configuration, JobAutoScalerContext<?>) - Static method in class org.apache.flink.autoscaler.tuning.MemoryTuning
getTransitionHistos() - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
getTriggerId() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
getTriggerId() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
getTriggerTimestamp() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getTriggerType() - Method in interface org.apache.flink.kubernetes.operator.api.status.Snapshot
getTriggerType() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
getTrimmedScalingHistory(AutoScalerStateStore<KEY, Context>, Context, Instant) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
getTrimmedScalingTracking(AutoScalerStateStore<KEY, Context>, Context, Instant) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
getUnresolvedMessageParameters() - Method in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
getUpgradeTargetGeneration(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Get spec generation for the current in progress upgrade.
getUsed() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesResource
getValueWithThreshold(Configuration, ConfigOption<T>, T) - Static method in class org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils: Gets the value of ConfigOption with threshold.
getVertexResources(RestClusterClient<String>, AbstractFlinkResource<?, ?>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
GLOBAL - org.apache.flink.autoscaler.topology.ShipStrategy
gracePeriodEnded(Duration, SnapshotInfo) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils

H

handle(AdmissionRequest) - Method in class org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator
handleCanaryResourceDeletion(CR) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
handleCanaryResourceReconciliation(CR, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.health.CanaryResourceManager
handleEvent(Context, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler: Handle the event.
handleEvent(Context, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in class org.apache.flink.autoscaler.event.LoggingEventHandler
handleEvent(Context, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcAutoScalerEventHandler
handleEvent(KubernetesJobAutoScalerContext, AutoScalerEventHandler.Type, String, String, String, Duration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler
handleScalingEvent(Context, Map<JobVertexID, ScalingSummary>, String, Duration) - Method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler: Handle scaling reports.
handleScalingEvent(Context, Map<JobVertexID, ScalingSummary>, String, Duration) - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcAutoScalerEventHandler
handleScalingEvent(KubernetesJobAutoScalerContext, Map<JobVertexID, ScalingSummary>, String, Duration) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler
HASH - org.apache.flink.autoscaler.topology.ShipStrategy
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.
HEAP_MAX_USAGE_RATIO - org.apache.flink.autoscaler.metrics.ScalingMetric: Percentage of max heap used (between 0 and 1).
HEAP_MEMORY_MAX - org.apache.flink.autoscaler.metrics.FlinkMetric
HEAP_MEMORY_USED - org.apache.flink.autoscaler.metrics.FlinkMetric
HEAP_MEMORY_USED - org.apache.flink.autoscaler.metrics.ScalingMetric: Measured max used heap size in bytes.
HEAP_USAGE_MESSAGE - Static variable in class org.apache.flink.autoscaler.ScalingExecutor
HEAP_USAGE_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
HISTO - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
hostname - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
HTTP_REQUEST_FAILED_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_REQUEST_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_RESPONSE_1XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_RESPONSE_2XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_RESPONSE_3XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_RESPONSE_4XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_RESPONSE_5XX - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HTTP_RESPONSE_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
HttpArtifactFetcher - Class in org.apache.flink.kubernetes.operator.artifact: Download the jar from the http resource.
HttpArtifactFetcher() - Constructor for class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
HttpBootstrap - Class in org.apache.flink.kubernetes.operator.health: Class for serving HTTP requests for the health probe.
HttpBootstrap(HealthProbe, int) - Constructor for class org.apache.flink.kubernetes.operator.health.HttpBootstrap

I

IGNORE - org.apache.flink.kubernetes.operator.api.diff.DiffType: Ignorable spec change.
inc() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
inc(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
INCREMENTAL - org.apache.flink.kubernetes.operator.api.status.CheckpointType
incrementBalanced() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
incrementError() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
incrementScaling() - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
INEFFECTIVE_MESSAGE_FORMAT - Static variable in class org.apache.flink.autoscaler.JobVertexScaler
INEFFECTIVE_SCALING - Static variable in class org.apache.flink.autoscaler.JobVertexScaler
IneffectiveScaling - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
inExcludedPeriods(Configuration, Instant) - Static method in class org.apache.flink.autoscaler.utils.CalendarUtils
InformerHealthSummary - Class in org.apache.flink.kubernetes.operator.health: Operator informer health summary.
InformerHealthSummary() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerHealthSummary
InformerIdentifier - Class in org.apache.flink.kubernetes.operator.health: Operator informer identifier.
InformerIdentifier() - Constructor for class org.apache.flink.kubernetes.operator.health.InformerIdentifier
InformerManager - Class in org.apache.flink.kubernetes.operator.admission.informer: The manager of the informers.
InformerManager(KubernetesClient) - Constructor for class org.apache.flink.kubernetes.operator.admission.informer.InformerManager
ingressInNetworkingV1(KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils
IngressSpec - Class in org.apache.flink.kubernetes.operator.api.spec: Ingress spec.
IngressSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.IngressSpec
IngressUtils - Class in org.apache.flink.kubernetes.operator.utils: Ingress utilities.
IngressUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.IngressUtils
init(Locale, Reporter) - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
initOperatorMetrics(Configuration) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
initRecommendedParallelism(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Static method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
initSpec() - Method in class org.apache.flink.kubernetes.operator.api.FlinkDeployment
initSpec() - Method in class org.apache.flink.kubernetes.operator.api.FlinkSessionJob
InitStandaloneTaskManagerDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators: An initializer for the TaskManager FlinkPod in standalone mode.
InitStandaloneTaskManagerDecorator(StandaloneKubernetesTaskManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.InitStandaloneTaskManagerDecorator
initStatus() - Method in class org.apache.flink.kubernetes.operator.api.FlinkDeployment
initStatus() - Method in class org.apache.flink.kubernetes.operator.api.FlinkSessionJob
InMemoryAutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.state: State store based on the Java Heap, the state will be discarded after process restarts.
InMemoryAutoScalerStateStore() - Constructor for class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
INSTANCE - org.apache.flink.kubernetes.operator.health.HealthProbe
INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
INSTANCE - Static variable in class org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders
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
IOMetrics - Class in org.apache.flink.autoscaler.topology: Vertex io metrics.
IOMetrics() - Constructor for class org.apache.flink.autoscaler.topology.IOMetrics
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
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
isEqualOrNewer(FlinkVersion) - Method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
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
isPipelineClasspathDefined() - Method in class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
isProcessingBacklog(JobTopology, SortedMap<Instant, CollectedMetrics>, Configuration) - Static method in class org.apache.flink.autoscaler.ScalingMetricEvaluator
isRecordsReadComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
isRecordsWrittenComplete() - Method in class org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
isResourceReadyToBeObserved(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver: Check whether the resource should be observed.
isResourceReadyToBeObserved(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
isScaledUp() - Method in class org.apache.flink.autoscaler.ScalingSummary
isSnapshotTriggeringSupported(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils
isSource(JobVertexID) - Method in class org.apache.flink.autoscaler.topology.JobTopology
isSupported(FlinkVersion) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
isSuspendedJob(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
isUpgradeModeChangedToLastStateAndHADisabledPreviously(AbstractFlinkResource<?, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
isValid(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
isZookeeperHAActivated(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
isZookeeperHaMetadataAvailable(Configuration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils

J

JAR_ARTIFACT_HTTP_HEADER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
JDBC - org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory.EventHandlerType
JDBC - org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory.StateStoreType
JDBC_PASSWORD_ENV_VARIABLE - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
JDBC_URL - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
JDBC_USERNAME - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
JdbcAutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.jdbc.event: The event handler which persists its event in JDBC related database.
JdbcAutoScalerEventHandler(JdbcEventInteractor) - Constructor for class org.apache.flink.autoscaler.jdbc.event.JdbcAutoScalerEventHandler
JdbcAutoScalerStateStore<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.jdbc.state: The state store which persists its state in JDBC related database.
JdbcAutoScalerStateStore(JdbcStateStore) - Constructor for class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
JdbcEventInteractor - Class in org.apache.flink.autoscaler.jdbc.event: Responsible for interacting with the database.
JdbcEventInteractor(Connection) - Constructor for class org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
JdbcStateInteractor - Class in org.apache.flink.autoscaler.jdbc.state: Responsible for interacting with the database.
JdbcStateInteractor(Connection) - Constructor for class org.apache.flink.autoscaler.jdbc.state.JdbcStateInteractor
JdbcStateStore - Class in org.apache.flink.autoscaler.jdbc.state: The jdbc state store.
JdbcStateStore(JdbcStateInteractor) - Constructor for class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
jmPodNeverStarted(Context<?>) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils: Check if the jobmanager pod has never successfully started.
Job - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
JOB_UPGRADE_IGNORE_PENDING_SAVEPOINT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
JOB_UPGRADE_INPLACE_SCALING_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
JOB_VERTEX_ID - Static variable in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
JobAutoScaler<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler: Flink Job AutoScaler.
JobAutoScalerContext<KEY> - Class in org.apache.flink.autoscaler: The job autoscaler context, it includes all details related to the current job.
JobAutoScalerContext() - Constructor for class org.apache.flink.autoscaler.JobAutoScalerContext
JobAutoScalerImpl<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler: The default implementation of JobAutoScaler.
JobAutoScalerImpl(ScalingMetricCollector<KEY, Context>, ScalingMetricEvaluator, ScalingExecutor<KEY, Context>, AutoScalerEventHandler<KEY, Context>, ScalingRealizer<KEY, Context>, AutoScalerStateStore<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.JobAutoScalerImpl
JobListFetcher<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.standalone: The JobListFetcher will fetch the jobContext of all jobs.
JOBMANAGER_ENTRYPOINT_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
JobManagerDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
JobManagerDeploymentStatus - Enum in org.apache.flink.kubernetes.operator.api.status: Status of the Flink JobManager Kubernetes deployment.
JobManagerSpec - Class in org.apache.flink.kubernetes.operator.api.spec: JobManager spec.
JobManagerSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.JobManagerSpec
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.
JobStateView - Class in org.apache.flink.autoscaler.jdbc.state: The view of job state.
JobStateView(JdbcStateInteractor, String) - Constructor for class org.apache.flink.autoscaler.jdbc.state.JobStateView
JobStatus - Class in org.apache.flink.kubernetes.operator.api.status: Last observed status of the Flink job within an application deployment.
JobStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.JobStatus
JobStatusChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
JobStatusObserver<R extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.observer: An observer to observe the job status.
JobStatusObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
jobsWithGcMetrics - Variable in class org.apache.flink.autoscaler.ScalingMetricCollector
JobTopology - Class in org.apache.flink.autoscaler.topology: Structure representing information about the jobgraph that is relevant for scaling.
JobTopology(Collection<VertexInfo>) - Constructor for class org.apache.flink.autoscaler.topology.JobTopology
JobTopology(Set<VertexInfo>) - Constructor for class org.apache.flink.autoscaler.topology.JobTopology
JobTopology(VertexInfo...) - Constructor for class org.apache.flink.autoscaler.topology.JobTopology
JobVertexScaler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler: Component responsible for computing vertex parallelism based on the scaling metrics.
JobVertexScaler(AutoScalerEventHandler<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.JobVertexScaler

K

K8S_OP_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
KIND_FLINK_DEPLOYMENT - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
KIND_SESSION_JOB - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
KUBE_CLIENT_GROUP - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
KUBERNETES_TASKMANAGER_REPLICAS - Static variable in class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
KubernetesAutoScalerEventHandler - Class in org.apache.flink.kubernetes.operator.autoscaler: An event handler which posts events to the Kubernetes events API.
KubernetesAutoScalerEventHandler(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler
KubernetesAutoScalerStateStore - Class in org.apache.flink.kubernetes.operator.autoscaler.state: An AutoscalerStateStore which persists its state in Kubernetes ConfigMaps.
KubernetesAutoScalerStateStore(ConfigMapStore) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
kubernetesClient - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
KubernetesClientMetrics - Class in org.apache.flink.kubernetes.operator.metrics: Kubernetes client metrics.
KubernetesClientMetrics(MetricGroup, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
KubernetesClientUtils - Class in org.apache.flink.kubernetes.operator.utils: Kubernetes client utils.
KubernetesClientUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
KubernetesDeploymentMode - Enum in org.apache.flink.kubernetes.operator.api.spec: Enum to control Flink deployment mode on Kubernetes.
KubernetesJobAutoScalerContext - Class in org.apache.flink.kubernetes.operator.autoscaler: An implementation of JobAutoscalerContext for Kubernetes.
KubernetesJobAutoScalerContext(JobID, JobStatus, Configuration, MetricGroup, SupplierWithException<RestClusterClient<String>, Exception>, FlinkResourceContext<?>) - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext
KubernetesNodeResourceInfo - Class in org.apache.flink.kubernetes.operator.resources: A single Kubernetes node and its resources (cpu / memory).
KubernetesNodeResourceInfo() - Constructor for class org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
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
KubernetesResource - Class in org.apache.flink.kubernetes.operator.resources: A Kubernetes resource and its current allocation.
KubernetesResource() - Constructor for class org.apache.flink.kubernetes.operator.resources.KubernetesResource
KubernetesResourceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics: Base metric group for Flink Operator Resource level metrics.
KubernetesResourceMetricGroup(MetricRegistry, KubernetesResourceNamespaceMetricGroup, String[], String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
KubernetesResourceNamespaceMetricGroup - Class in org.apache.flink.kubernetes.operator.metrics: Base metric group for Flink Operator Resource namespace level metrics.
KubernetesResourceNamespaceMetricGroup(MetricRegistry, KubernetesOperatorMetricGroup, String[], String, String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
KubernetesResourceNamespaceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics: Format for metrics.
KubernetesResourceNamespaceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
KubernetesResourceScopeFormat - Class in org.apache.flink.kubernetes.operator.metrics: Format for metrics.
KubernetesResourceScopeFormat(String) - Constructor for class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
KubernetesScalingRealizer - Class in org.apache.flink.kubernetes.operator.autoscaler: The Kubernetes implementation for applying parallelism overrides.
KubernetesScalingRealizer() - Constructor for class org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer
KubernetesStandaloneClusterDescriptor - Class in org.apache.flink.kubernetes.operator.standalone: Standalone Kubernetes specific ClusterDescriptor implementation.
KubernetesStandaloneClusterDescriptor(Configuration, FlinkStandaloneKubeClient) - Constructor for class org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor

L

LABEL_TARGET_SESSION - Static variable in class org.apache.flink.kubernetes.operator.api.CrdConstants
LABEL_TYPE_STANDALONE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
LABELS - Static variable in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
LAG - org.apache.flink.autoscaler.metrics.ScalingMetric: Total number of pending records.
LAST_STATE - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode: Job is upgraded using any latest checkpoint or savepoint available.
LifecycleMetrics<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle: Utility for tracking resource lifecycle metrics globally and per namespace.
LifecycleMetrics(Configuration, KubernetesOperatorMetricGroup) - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
LifecycleMetrics.Transition - Class in org.apache.flink.kubernetes.operator.metrics.lifecycle: Pojo for encapsulating state transitions and whether we should measure time from the beginning of from or since the last update.
ListenerUtils - Class in org.apache.flink.kubernetes.operator.listener: Flink resource listener utilities.
ListenerUtils() - Constructor for class org.apache.flink.kubernetes.operator.listener.ListenerUtils
listJobs(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
listJobs(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
LOAD - org.apache.flink.autoscaler.metrics.ScalingMetric: Subtask load (busy time ratio 0 (idle) to 1 (fully utilized)).
loadGlobalConfiguration(Optional<String>) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager
loadListenerConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.listener.ListenerUtils
LoadSimulationPipeline - Class in autoscaling: Example pipeline which simulates fluctuating load from zero to a defined max, and vice-versa.
LoadSimulationPipeline() - Constructor for class autoscaling.LoadSimulationPipeline
LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
LOG - Static variable in class org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher
logContext(FlinkResourceListener.ResourceEventContext<R>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils
logContext(FlinkResourceListener.StatusUpdateContext<R, S>) - Static method in class org.apache.flink.kubernetes.operator.listener.AuditUtils
logEnvironmentInfo(Logger, String, String[]) - Static method in class org.apache.flink.kubernetes.operator.utils.EnvUtils: Logs information about the environment, like code revision, current user, Java version, and JVM parameters.
logger - Variable in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
logger - Variable in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
LOGGING - org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory.EventHandlerType
LoggingEventHandler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.event: Autoscaler event handler which logs events.
LoggingEventHandler() - Constructor for class org.apache.flink.autoscaler.event.LoggingEventHandler

M

main(String[]) - Static method in class autoscaling.AutoscalingExample
main(String[]) - Static method in class autoscaling.LoadSimulationPipeline
main(String[]) - Static method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint
main(String[]) - Static method in class org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook
main(String[]) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
main(String[]) - Static method in class org.apache.flink.kubernetes.operator.docs.configuration.ConfigOptionsDocGenerator: This method generates html tables from set of classes containing ConfigOptions.
main(String...) - Static method in class org.apache.flink.kubernetes.operator.FlinkOperator
MANAGED_MEMORY_USED - org.apache.flink.autoscaler.metrics.FlinkMetric
MANAGED_MEMORY_USED - org.apache.flink.autoscaler.metrics.ScalingMetric: Measured max managed memory size in bytes.
MANUAL - org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType: Snapshot manually triggered by changing a triggerNonce.
markEvent() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
markEvent(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
markReconciledSpecAsStable() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
MAX - org.apache.flink.autoscaler.metrics.MetricAggregator
MAX_CM_BYTES - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
MAX_PARALLELISM - org.apache.flink.autoscaler.metrics.ScalingMetric: Job vertex max parallelism.
MAX_SCALE_DOWN_FACTOR - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
MAX_SCALE_UP_FACTOR - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
measureFromLastUpdate - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
MEMORY - org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory.StateStoreType
MEMORY_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
MEMORY_SCALING_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
MEMORY_TUNING_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
MEMORY_TUNING_MAXIMIZE_MANAGED_MEMORY - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
MEMORY_TUNING_OVERHEAD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
MemoryBudget - Class in org.apache.flink.autoscaler.tuning: Accounting for distributing memory over the available pools.
MemoryBudget(long) - Constructor for class org.apache.flink.autoscaler.tuning.MemoryBudget
MemoryPressure - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
MemoryScaling - Class in org.apache.flink.autoscaler.tuning: Memory scaling ensures that memory is scaled alongside with the number of available TaskManagers.
MemoryScaling() - Constructor for class org.apache.flink.autoscaler.tuning.MemoryScaling
MemoryTuning - Class in org.apache.flink.autoscaler.tuning: Tunes the TaskManager memory.
MemoryTuning() - Constructor for class org.apache.flink.autoscaler.tuning.MemoryTuning
mergePodTemplates(PodTemplateSpec, PodTemplateSpec, boolean) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkUtils
METASPACE_MEMORY_USED - org.apache.flink.autoscaler.metrics.FlinkMetric
METASPACE_MEMORY_USED - org.apache.flink.autoscaler.metrics.ScalingMetric: Measured max metaspace memory size in bytes.
METER - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics
MetricAggregator - Enum in org.apache.flink.autoscaler.metrics: Enum specifying which aggregator to use when getting a metric value.
MetricManager<CR extends AbstractFlinkResource<?,?>> - Class in org.apache.flink.kubernetes.operator.metrics: Metric manager for Operator managed custom resources.
MetricManager() - Constructor for class org.apache.flink.kubernetes.operator.metrics.MetricManager
metricName - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
MetricNotFoundException - Exception in org.apache.flink.autoscaler.metrics: Exception for when an expected metric was not found.
MetricNotFoundException(FlinkMetric, JobVertexID) - Constructor for exception org.apache.flink.autoscaler.metrics.MetricNotFoundException
METRICS_WINDOW - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
MIN - org.apache.flink.autoscaler.metrics.MetricAggregator
Missing - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
MISSING - org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus: JobManager deployment not found, probably not started or killed by user.
MISSING_SESSION_JOB_ERR - Static variable in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver
MissingJobManagerException - Exception in org.apache.flink.kubernetes.operator.exception: Exception to signal missing job manager.
MissingJobManagerException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
MissingJobManagerException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
MissingJobManagerException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
MissingSessionJobException - Exception in org.apache.flink.kubernetes.operator.exception: Exception to signal missing session job.
MissingSessionJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
MissingSessionJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
MissingSessionJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
mode() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry
mode() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff
Mode - Enum in org.apache.flink.kubernetes.operator.config: The mode of FlinkDeployment.
monitorSizeOf(T, String) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
MSG_ROLLBACK - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
MSG_SPEC_CHANGED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
MSG_SUBMIT - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
MSG_SUSPENDED - Static variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
mutate(HasMetadata, Operation) - Method in class org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator
mutateDeployment(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.mutator.DefaultFlinkMutator
mutateDeployment(FlinkDeployment) - Method in interface org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator: Mutate deployment and return the mutated Object.
mutateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.mutator.DefaultFlinkMutator
mutateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator: Mutate session job and return the mutated Object.
MUTATOR_REQUEST_PATH - Static variable in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
MutatorUtils - Class in org.apache.flink.kubernetes.operator.utils: Mutator utilities.
MutatorUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.MutatorUtils

N

name - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
namespace - Variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
NAMESPACE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
NAMESPACE_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
NATIVE - org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode: Deploys Flink using Flinks native Kubernetes support.
NATIVE - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType: A format specific for the chosen state backend.
NativeFlinkService - Class in org.apache.flink.kubernetes.operator.service: Implementation of FlinkService submitting and interacting with Native Kubernetes Flink clusters and jobs.
NativeFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration, EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.service.NativeFlinkService
newConfigWithOverrides(Configuration) - Method in class org.apache.flink.autoscaler.tuning.ConfigChanges
newEngine(ByteBufAllocator) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
newEngine(ByteBufAllocator, String, int) - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
NoopJobAutoscaler<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler: An autoscaler implementation which does nothing.
NoopJobAutoscaler() - Constructor for class org.apache.flink.autoscaler.NoopJobAutoscaler
NoopResourceCheck - Class in org.apache.flink.autoscaler.resources: Noop implementation for checking for available resources.
NoopResourceCheck() - Constructor for class org.apache.flink.autoscaler.resources.NoopResourceCheck
Normal - org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type
Normal - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
NotReadyException - Exception in org.apache.flink.autoscaler.exceptions: An exception to indicate the called code wasn't ready but will be at a later point in time.
NotReadyException(Exception) - Constructor for exception org.apache.flink.autoscaler.exceptions.NotReadyException
NUM_RECORDS_IN - org.apache.flink.autoscaler.metrics.ScalingMetric
NUM_RECORDS_OUT - org.apache.flink.autoscaler.metrics.ScalingMetric
NUM_TASK_SLOTS_AVAILABLE - org.apache.flink.autoscaler.metrics.FlinkMetric
NUM_TASK_SLOTS_TOTAL - org.apache.flink.autoscaler.metrics.FlinkMetric
NUM_TASK_SLOTS_USED - org.apache.flink.autoscaler.metrics.ScalingMetric

O

objectMapper - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
observe(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver
observe(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.observer.Observer: Observe the flinkApp status, It will reflect the changed status on the flinkApp resource.
observe(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver: Observe the health of the flink cluster.
observe(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver: Observe the status of the flink job.
OBSERVE_TRUE_PROCESSING_RATE_LAG_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
observeCheckpointStatus(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.SnapshotObserver
OBSERVED_TPR - org.apache.flink.autoscaler.metrics.ScalingMetric: Observed true processing rate for sources.
OBSERVED_TRUE_PROCESSING_RATE_MIN_OBSERVATIONS - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
OBSERVED_TRUE_PROCESSING_RATE_SWITCH_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver: Observe the flinkApp status when the cluster is ready.
observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver
observeFlinkCluster(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver
observeInternal(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver: Internal observer logic specific to each resource type.
observeInternal(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
observeInternal(FlinkResourceContext<FlinkSessionJob>) - Method in class org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
observeJmDeployment(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
Observer<CR extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.observer: The Observer of custom resource.
observeSavepointStatus(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.observer.SnapshotObserver
of(double) - Static method in class org.apache.flink.autoscaler.metrics.EvaluatedScalingMetric
of(long, SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Checkpoint
of(String) - Static method in enum org.apache.flink.autoscaler.topology.ShipStrategy: Generates a ShipStrategy from a string, or returns ShipStrategy.UNKNOWN if the value cannot match any ShipStrategy.
of(String, long, SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint
of(String, SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint
of(String, SnapshotTriggerType, SavepointFormatType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Savepoint
of(Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceManager
of(SnapshotTriggerType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Checkpoint
of(SnapshotTriggerType, CheckpointType) - Static method in class org.apache.flink.kubernetes.operator.api.status.Checkpoint
OLD_K8S_OP_CONF_PREFIX - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
onDeploymentEvent(FlinkResourceListener.ResourceEventContext<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
onDeploymentStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkDeployment, FlinkDeploymentStatus>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
onFileOrDirectoryCreated(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
onFileOrDirectoryDeleted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
onFileOrDirectoryModified(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
onNoJobsFound(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver: Callback when no jobs were found on the cluster.
onNullIgnore() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff
onRemove(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics
onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
onRemove(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
onRemove(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
onRemove(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
onSessionJobEvent(FlinkResourceListener.ResourceEventContext<FlinkSessionJob>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
onSessionJobStatusUpdate(FlinkResourceListener.StatusUpdateContext<FlinkSessionJob, FlinkSessionJobStatus>) - Method in interface org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
onTargetJobNotFound(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver: Callback when no matching target job was found on a cluster where jobs were found.
onTimeout(FlinkResourceContext<R>) - Method in class org.apache.flink.kubernetes.operator.observer.JobStatusObserver: Callback when list jobs timeout.
onUpdate(CR) - Method in interface org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics
onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
onUpdate(CR) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
onUpdate(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
onUpdate(FlinkSessionJob) - Method in class org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics
onUpdate(ResourceLifecycleState, Instant) - Method in class org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
onWatchStarted(Path) - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
Operator - org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
OPERATOR_CHECKPOINT_TRIGGER_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CHECKPOINT_TYPE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CLUSTER_HEALTH_CHECK_CHECKPOINT_PROGRESS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CLUSTER_HEALTH_CHECK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CLUSTER_HEALTH_CHECK_RESTARTS_WINDOW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CONFIG_CACHE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_CONFIG_CACHE_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_DYNAMIC_CONFIG_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_DYNAMIC_CONFIG_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_DYNAMIC_NAMESPACES_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_EXCEPTION_FIELD_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_EXCEPTION_LABEL_MAPPER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_EXCEPTION_STACK_TRACE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_EXCEPTION_STACK_TRACE_MAX_LENGTH - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_EXCEPTION_THROWABLE_LIST_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_FLINK_CLIENT_CANCEL_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_FLINK_CLIENT_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_HEALTH_PROBE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_HEALTH_PROBE_PORT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JM_DEPLOYMENT_RECOVERY_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JM_SHUTDOWN_TTL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JM_STARTUP_PROBE_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JOB_RESTART_FAILED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JOB_UPGRADE_LAST_STATE_CHECKPOINT_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JOB_UPGRADE_LAST_STATE_FALLBACK_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_JOSDK_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_JVM_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_KUBERNETES_CLIENT_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_KUBERNETES_CLIENT_METRICS_HTTP_RESPONSE_CODE_GROUPS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_LABEL_SELECTOR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_LEADER_ELECTION_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_LEADER_ELECTION_LEASE_DURATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_LEADER_ELECTION_LEASE_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_LEADER_ELECTION_RENEW_DEADLINE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_LEADER_ELECTION_RETRY_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_LIFECYCLE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_LIFECYCLE_NAMESPACE_HISTOGRAMS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_METRICS_HISTOGRAM_SAMPLE_SIZE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_OBSERVER_PROGRESS_CHECK_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_OBSERVER_REST_READY_DELAY - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RATE_LIMITER_LIMIT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RATE_LIMITER_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RECONCILE_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RECONCILE_PARALLELISM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RESOURCE_CLEANUP_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RESOURCE_METRICS_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
OPERATOR_RETRY_INITIAL_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RETRY_INTERVAL_MULTIPLIER - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RETRY_MAX_ATTEMPTS - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_RETRY_MAX_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_CLEANUP_ENABLED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_FORMAT_TYPE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_HISTORY_MAX_AGE - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_HISTORY_MAX_AGE_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_HISTORY_MAX_COUNT_THRESHOLD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_SAVEPOINT_TRIGGER_GRACE_PERIOD - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_STOP_ON_INFORMER_ERROR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_TERMINATION_TIMEOUT - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_USER_ARTIFACTS_BASE_DIR - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OPERATOR_WATCHED_NAMESPACES - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
operatorConfig - Variable in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
operatorConfig(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
operatorConfigKey(String) - Static method in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
OperatorHealthHandler - Class in org.apache.flink.kubernetes.operator.health: Simple code which returns HTTP 200 messages if the service is live, and HTTP 500 messages if the service is down.
OperatorHealthHandler() - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthHandler
OperatorHealthService - Class in org.apache.flink.kubernetes.operator.health: Health probe service.
OperatorHealthService(FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.health.OperatorHealthService
OperatorJosdkMetrics - Class in org.apache.flink.kubernetes.operator.metrics: Implementation of Metrics to monitor and forward JOSDK metrics to MetricRegistry.
OperatorJosdkMetrics(KubernetesOperatorMetricGroup, FlinkConfigManager) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
OperatorMetricUtils - Class in org.apache.flink.kubernetes.operator.metrics: Utility class for flink based operator metrics.
OperatorMetricUtils() - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
OperatorMetricUtils.SynchronizedCounter - Class in org.apache.flink.kubernetes.operator.metrics: Thread safe Counter wrapper.
OperatorMetricUtils.SynchronizedHistogram - Class in org.apache.flink.kubernetes.operator.metrics: Thread safe Histogram wrapper.
OperatorMetricUtils.SynchronizedMeterView - Class in org.apache.flink.kubernetes.operator.metrics: Thread safe MeterView wrapper.
org.apache.flink.autoscaler - package org.apache.flink.autoscaler
org.apache.flink.autoscaler.config - package org.apache.flink.autoscaler.config
org.apache.flink.autoscaler.event - package org.apache.flink.autoscaler.event
org.apache.flink.autoscaler.exceptions - package org.apache.flink.autoscaler.exceptions
org.apache.flink.autoscaler.jdbc.event - package org.apache.flink.autoscaler.jdbc.event
org.apache.flink.autoscaler.jdbc.state - package org.apache.flink.autoscaler.jdbc.state
org.apache.flink.autoscaler.metrics - package org.apache.flink.autoscaler.metrics
org.apache.flink.autoscaler.realizer - package org.apache.flink.autoscaler.realizer
org.apache.flink.autoscaler.resources - package org.apache.flink.autoscaler.resources
org.apache.flink.autoscaler.standalone - package org.apache.flink.autoscaler.standalone
org.apache.flink.autoscaler.standalone.config - package org.apache.flink.autoscaler.standalone.config
org.apache.flink.autoscaler.standalone.flinkcluster - package org.apache.flink.autoscaler.standalone.flinkcluster
org.apache.flink.autoscaler.standalone.realizer - package org.apache.flink.autoscaler.standalone.realizer
org.apache.flink.autoscaler.state - package org.apache.flink.autoscaler.state
org.apache.flink.autoscaler.topology - package org.apache.flink.autoscaler.topology
org.apache.flink.autoscaler.tuning - package org.apache.flink.autoscaler.tuning
org.apache.flink.autoscaler.utils - package org.apache.flink.autoscaler.utils
org.apache.flink.kubernetes.operator - package org.apache.flink.kubernetes.operator
org.apache.flink.kubernetes.operator.admission - package org.apache.flink.kubernetes.operator.admission
org.apache.flink.kubernetes.operator.admission.informer - package org.apache.flink.kubernetes.operator.admission.informer
org.apache.flink.kubernetes.operator.admission.mutator - package org.apache.flink.kubernetes.operator.admission.mutator
org.apache.flink.kubernetes.operator.api - package org.apache.flink.kubernetes.operator.api
org.apache.flink.kubernetes.operator.api.diff - package org.apache.flink.kubernetes.operator.api.diff
org.apache.flink.kubernetes.operator.api.docs - package org.apache.flink.kubernetes.operator.api.docs
org.apache.flink.kubernetes.operator.api.lifecycle - package org.apache.flink.kubernetes.operator.api.lifecycle
org.apache.flink.kubernetes.operator.api.listener - package org.apache.flink.kubernetes.operator.api.listener
org.apache.flink.kubernetes.operator.api.reconciler - package org.apache.flink.kubernetes.operator.api.reconciler
org.apache.flink.kubernetes.operator.api.spec - package org.apache.flink.kubernetes.operator.api.spec
org.apache.flink.kubernetes.operator.api.status - package org.apache.flink.kubernetes.operator.api.status
org.apache.flink.kubernetes.operator.api.utils - package org.apache.flink.kubernetes.operator.api.utils
org.apache.flink.kubernetes.operator.api.validation - package org.apache.flink.kubernetes.operator.api.validation
org.apache.flink.kubernetes.operator.artifact - package org.apache.flink.kubernetes.operator.artifact
org.apache.flink.kubernetes.operator.autoscaler - package org.apache.flink.kubernetes.operator.autoscaler
org.apache.flink.kubernetes.operator.autoscaler.state - package org.apache.flink.kubernetes.operator.autoscaler.state
org.apache.flink.kubernetes.operator.config - package org.apache.flink.kubernetes.operator.config
org.apache.flink.kubernetes.operator.controller - package org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.docs.configuration - package org.apache.flink.kubernetes.operator.docs.configuration
org.apache.flink.kubernetes.operator.docs.util - package org.apache.flink.kubernetes.operator.docs.util
org.apache.flink.kubernetes.operator.exception - package org.apache.flink.kubernetes.operator.exception
org.apache.flink.kubernetes.operator.fs - package org.apache.flink.kubernetes.operator.fs
org.apache.flink.kubernetes.operator.health - package org.apache.flink.kubernetes.operator.health
org.apache.flink.kubernetes.operator.kubeclient - package org.apache.flink.kubernetes.operator.kubeclient
org.apache.flink.kubernetes.operator.kubeclient.decorators - package org.apache.flink.kubernetes.operator.kubeclient.decorators
org.apache.flink.kubernetes.operator.kubeclient.factory - package org.apache.flink.kubernetes.operator.kubeclient.factory
org.apache.flink.kubernetes.operator.kubeclient.parameters - package org.apache.flink.kubernetes.operator.kubeclient.parameters
org.apache.flink.kubernetes.operator.listener - package org.apache.flink.kubernetes.operator.listener
org.apache.flink.kubernetes.operator.metrics - package org.apache.flink.kubernetes.operator.metrics
org.apache.flink.kubernetes.operator.metrics.lifecycle - package org.apache.flink.kubernetes.operator.metrics.lifecycle
org.apache.flink.kubernetes.operator.mutator - package org.apache.flink.kubernetes.operator.mutator
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.resources - package org.apache.flink.kubernetes.operator.resources
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.autoscaler.metrics.ScalingMetric: Job vertex parallelism.
PARALLELISM_MAP_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler
PARALLELISM_OVERRIDES - org.apache.flink.autoscaler.jdbc.state.StateType
PARALLELISM_OVERRIDES_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
parseResourceMemoryString(String) - Static method in class org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
parseVertexScalingReports(String) - Static method in class org.apache.flink.autoscaler.event.AutoscalerEventUtils: Parse the scaling report from original scaling report event.
patchAndCacheStatus(CR, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder: Update the status of the provided kubernetes resource on the k8s cluster.
pending() - Static method in class org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult
pending() - Static method in class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
PENDING - org.apache.flink.kubernetes.operator.utils.SnapshotStatus: Snapshot is pending, could be in the retry phase in the case of manual snapshots.
PENDING_RECORDS - org.apache.flink.autoscaler.metrics.FlinkMetric
PendingCheckpointInfo() - Constructor for class org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.PendingCheckpointInfo
PERIODIC - org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType: Snapshot periodically triggered by the operator.
PERIODIC_CHECKPOINT_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
PERIODIC_SAVEPOINT_INTERVAL - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
POD_IP_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
POD_TEMPLATE_MERGE_BY_NAME - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
predicate - Variable in enum org.apache.flink.autoscaler.metrics.FlinkMetric
PREFER_TRACKED_RESTART_TIME - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
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
put(StateType, String) - Method in class org.apache.flink.autoscaler.jdbc.state.JobStateView
putSerializedState(String, StateType, String) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
putSerializedState(KubernetesJobAutoScalerContext, String, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
putVariables(Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup

Q

queryAggregatedMetricNames(RestClusterClient<?>, JobID, JobVertexID) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
queryAggregatedTmMetrics(RestClusterClient<?>, Map<String, FlinkMetric>) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector
queryAggregatedVertexMetrics(Context, JobVertexID, Map<String, FlinkMetric>) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector
queryAllAggregatedMetrics(Context, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector
queryAllAggregatedMetrics(Context, Map<JobVertexID, Map<String, FlinkMetric>>) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
queryData(String) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateInteractor
queryEvents(String, String) - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
queryFilteredMetricNames(Context, JobTopology) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector: Query the available metric names for each job vertex.
queryJmMetrics(Context) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector
queryJmMetrics(Context) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
queryJmMetrics(RestClusterClient<?>, Map<String, FlinkMetric>) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector
queryLatestEvent(String, String, String) - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
queryTmMetrics(Context) - Method in class org.apache.flink.autoscaler.RestApiMetricsCollector
queryTmMetrics(Context) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector

R

readable(Instant) - Static method in class org.apache.flink.autoscaler.utils.DateTimeUtils: Convert an Instant to a readable format for the system default zone.
readable(Instant, ZoneId) - Static method in class org.apache.flink.autoscaler.utils.DateTimeUtils: Convert an Instant to a readable format for a given zone.
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
realizeConfigOverrides(Context, ConfigChanges) - Method in interface org.apache.flink.autoscaler.realizer.ScalingRealizer: Updates the TaskManager memory configuration.
realizeConfigOverrides(Context, ConfigChanges) - Method in class org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer
realizeConfigOverrides(KubernetesJobAutoScalerContext, ConfigChanges) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer
realizeParallelismOverrides(Context, Map<String, String>) - Method in interface org.apache.flink.autoscaler.realizer.ScalingRealizer: Update job's parallelism to parallelismOverrides.
realizeParallelismOverrides(Context, Map<String, String>) - Method in class org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer
realizeParallelismOverrides(KubernetesJobAutoScalerContext, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer
REASON_CRASH_LOOP_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
REASON_ERR_IMAGE_PULL - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
REASON_IMAGE_PULL_BACKOFF - Static variable in exception org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
REBALANCE - org.apache.flink.autoscaler.topology.ShipStrategy
receivedEvent(Event, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
RECOMMENDED_PARALLELISM - org.apache.flink.autoscaler.metrics.ScalingMetric: Recommended job vertex parallelism.
reconcile(FlinkDeployment, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
reconcile(FlinkSessionJob, Context) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
reconcile(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
reconcile(FlinkResourceContext<CR>) - Method in interface org.apache.flink.kubernetes.operator.reconciler.Reconciler: This is called when receiving the create or update event of the custom resource.
reconcileCustomResource(ResourceID, RetryInfo, Map<String, Object>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler: Reconcile any other changes required for this resource that are specific to the reconciler implementation.
reconcileOtherChanges(FlinkResourceContext<CR>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
reconcileOtherChanges(FlinkResourceContext<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
Reconciler<CR extends AbstractFlinkResource<?,?>> - Interface in org.apache.flink.kubernetes.operator.reconciler: The interface of reconciler.
ReconcilerFactory - Class in org.apache.flink.kubernetes.operator.reconciler.deployment: The factory to create reconciler based on app mode.
ReconcilerFactory(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory
reconcileSpecChange(DiffType, FlinkResourceContext<CR>, Configuration, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler: Reconcile spec upgrade on the currently deployed/suspended Flink resource and update the status accordingly.
reconcileSpecChange(DiffType, FlinkResourceContext<CR>, Configuration, SPEC) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
reconcileSpecChange(DiffType, FlinkResourceContext<FlinkDeployment>, Configuration, FlinkDeploymentSpec) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
ReconciliationException - Exception in org.apache.flink.kubernetes.operator.exception: Exception for wrapping reconciliation errors.
ReconciliationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException
ReconciliationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException
ReconciliationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ReconciliationException
ReconciliationMetadata - Class in org.apache.flink.kubernetes.operator.api.reconciler: Extra metadata to be attached to the reconciled spec.
ReconciliationMetadata() - Constructor for class org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata
ReconciliationState - Enum in org.apache.flink.kubernetes.operator.api.status: Current state of the reconciliation.
ReconciliationStatus<SPEC extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.status: Status of the last reconcile step for the FlinkDeployment/FlinkSessionJob.
ReconciliationStatus() - Constructor for class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
ReconciliationUtils - Class in org.apache.flink.kubernetes.operator.reconciler: Reconciliation utilities.
ReconciliationUtils() - Constructor for class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
recordRestartDurationIfTrackedAndParallelismMatches(Instant, JobTopology, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.autoscaler.ScalingTracking: Sets restart duration for the latest scaling record if its parallelism matches the current job parallelism.
RecoverDeployment - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
RecoveryFailureException - Exception in org.apache.flink.kubernetes.operator.exception: Exception to signal non-terminal deployment failure.
RecoveryFailureException(String, String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.RecoveryFailureException
ReflectiveDiffBuilder<T> - Class in org.apache.flink.kubernetes.operator.reconciler.diff: Assists in comparing Diffable objects with reflection.
ReflectiveDiffBuilder(KubernetesDeploymentMode, T, T) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder
REFRESH_CLUSTER_RESOURCE_VIEW - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
register(CustomResourceMetrics<CR>) - Method in class org.apache.flink.kubernetes.operator.metrics.MetricManager
registerCanaryResourceManager(CanaryResourceManager<?>) - Method in enum org.apache.flink.kubernetes.operator.health.HealthProbe
registerScalingMetrics(List<JobVertexID>, Supplier<EvaluatedMetrics>) - Method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
release(double) - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesResource
release(double, MemorySize) - Method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceView
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
remove(StateType) - Method in class org.apache.flink.autoscaler.jdbc.state.JobStateView
removeCachedStatus(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder: Remove cached status for Flink resource.
removeCollectedMetrics(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
removeCollectedMetrics(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
removeCollectedMetrics(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
removeCollectedMetrics(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
removeConfigChanges(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
removeConfigChanges(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
removeConfigChanges(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
removeConfigChanges(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
removeInfoFromCache(ResourceID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
removeInfoFromCache(ResourceID) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
removeInfoFromCache(String) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
removeInfoFromCache(KEY) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
removeInfoFromCache(KEY) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore: Clean up all information related to the current job.
removeInfoFromCache(KEY) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
removeLastValidClusterHealthInfo(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
removeOldRecords(Instant, Duration, int) - Method in class org.apache.flink.autoscaler.ScalingTracking: Removes all but one records from the internal map that are older than the specified time span and trims the number of records to the specified maximum count.
removeOperatorConfigs(Configuration) - Static method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
removeParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
removeParallelismOverrides(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
removeParallelismOverrides(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
removeParallelismOverrides(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
removeScalingHistory(Context) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
removeScalingHistory(Context) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
removeScalingHistory(Context) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
removeScalingHistory(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
removeSerializedState(String, StateType) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
removeSerializedState(KubernetesJobAutoScalerContext, String) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
REPORTED_VERTEX_METRICS - Static variable in enum org.apache.flink.autoscaler.metrics.ScalingMetric: List of ScalingMetrics to be reported as per vertex Flink metrics.
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
RESCALE - org.apache.flink.autoscaler.topology.ShipStrategy
RescaleApiScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.standalone.realizer: A ScalingRealizer which uses the Rescale API to apply parallelism changes.
RescaleApiScalingRealizer(AutoScalerEventHandler<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer
rescheduleAfter(JobManagerDeploymentStatus, FlinkDeployment, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
resetPending() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
resetRecommendedParallelism(Map<JobVertexID, Map<ScalingMetric, EvaluatedScalingMetric>>) - Static method in class org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
resetSnapshotTriggers(AbstractFlinkResource<?, ?>, EventRecorder, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils
resetTrigger() - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
resetTrigger() - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
resetTrigger() - Method in interface org.apache.flink.kubernetes.operator.api.status.SnapshotInfo
Resource - Class in org.apache.flink.kubernetes.operator.api.spec: Resource spec.
Resource() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.Resource
RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
RESOURCE_DELETION_PROPAGATION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
RESOURCE_NS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
RESOURCE_TYPE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
RESOURCE_USAGE_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
ResourceCheck - Interface in org.apache.flink.autoscaler.resources: An interface for checking the available capacity of the underlying resources.
ResourceCheckUtils - Class in org.apache.flink.autoscaler.utils: Utils methods for resource checks.
ResourceCheckUtils() - Constructor for class org.apache.flink.autoscaler.utils.ResourceCheckUtils
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
RestApiMetricsCollector<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler: Metric collector using flink rest api.
RestApiMetricsCollector() - Constructor for class org.apache.flink.autoscaler.RestApiMetricsCollector
RESTART_TIME - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
RestartUnhealthyJob - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
restoreJob(FlinkResourceContext<CR>, SPEC, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
resubmitJob(FlinkResourceContext<CR>, boolean) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler
Rollback - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
ROLLED_BACK - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
ROLLED_BACK - org.apache.flink.kubernetes.operator.api.status.ReconciliationState: Rolled back to the lastStableSpec.
ROLLING_BACK - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
ROLLING_BACK - org.apache.flink.kubernetes.operator.api.status.ReconciliationState: In the process of rolling back to the lastStableSpec.
roundMetric(double) - Static method in class org.apache.flink.autoscaler.metrics.ScalingMetrics
run() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
run() - Method in class org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
run(DocletEnvironment) - Method in class org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet
runJar(JobSpec, JobID, JarUploadResponseBody, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
RUNNING - org.apache.flink.kubernetes.operator.api.spec.JobState: Job is expected to be processing data.

S

Savepoint - Class in org.apache.flink.kubernetes.operator.api.status: Represents information about a finished savepoint.
Savepoint(long, String, SnapshotTriggerType, SavepointFormatType, Long) - Constructor for class org.apache.flink.kubernetes.operator.api.status.Savepoint
SAVEPOINT - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode: Job is upgraded by first taking a savepoint of the running job, shutting it down and restoring from the savepoint.
SAVEPOINT - org.apache.flink.kubernetes.operator.reconciler.SnapshotType
SAVEPOINT_ON_DELETION - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
SAVEPOINT_REDEPLOY - org.apache.flink.kubernetes.operator.api.diff.DiffType: Full redeploy from new state.
SavepointError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
SavepointFetchResult - Class in org.apache.flink.kubernetes.operator.observer: Result of a fetch savepoint operation.
SavepointFetchResult() - Constructor for class org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
SavepointFormatType - Enum in org.apache.flink.kubernetes.operator.api.status: Savepoint format type.
SavepointInfo - Class in org.apache.flink.kubernetes.operator.api.status: Stores savepoint related information.
SavepointInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
savepointInProgress(JobStatus) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils
SavepointTriggerRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints: RequestBody to trigger savepoints.
SavepointTriggerRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody
scale(int, Collection<ShipStrategy>, int, double, int, int) - Static method in class org.apache.flink.autoscaler.JobVertexScaler: Computing the newParallelism.
scale(Context) - Method in interface org.apache.flink.autoscaler.JobAutoScaler: Compute and apply new parallelism overrides for the provided job context.
scale(Context) - Method in class org.apache.flink.autoscaler.JobAutoScalerImpl
scale(Context) - Method in class org.apache.flink.autoscaler.NoopJobAutoscaler
scale(FlinkResourceContext<?>, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
scale(FlinkResourceContext<?>, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
scale(FlinkResourceContext<?>, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
SCALE - org.apache.flink.kubernetes.operator.api.diff.DiffType: Scalable spec change.
SCALE_DOWN_RATE_THRESHOLD - org.apache.flink.autoscaler.metrics.ScalingMetric: Lower boundary of the target data rate range.
SCALE_UP_GRACE_PERIOD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
SCALE_UP_RATE_THRESHOLD - org.apache.flink.autoscaler.metrics.ScalingMetric: Upper boundary of the target data rate range.
scaleResource(Context, EvaluatedMetrics, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>, ScalingTracking, Instant, JobTopology) - Method in class org.apache.flink.autoscaler.ScalingExecutor
scaling() - Method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor
Scaling - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
SCALING_EFFECTIVENESS_DETECTION_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
SCALING_EFFECTIVENESS_THRESHOLD - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
SCALING_ENABLED - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
SCALING_EVENT_INTERVAL - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
SCALING_EXECUTION_DISABLED_REASON - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
SCALING_HISTORY - org.apache.flink.autoscaler.jdbc.state.StateType
SCALING_HISTORY_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
SCALING_REPORT_KEY - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
SCALING_REPORT_REASON - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
SCALING_SUMMARY_ENTRY - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
SCALING_SUMMARY_HEADER_SCALING_EXECUTION_DISABLED - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
SCALING_SUMMARY_HEADER_SCALING_EXECUTION_ENABLED - Static variable in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
SCALING_TRACKING - org.apache.flink.autoscaler.jdbc.state.StateType
SCALING_TRACKING_KEY - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
ScalingExecutor<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler: Class responsible for executing scaling decisions.
ScalingExecutor(AutoScalerEventHandler<KEY, Context>, AutoScalerStateStore<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.ScalingExecutor
ScalingExecutor(AutoScalerEventHandler<KEY, Context>, AutoScalerStateStore<KEY, Context>, ResourceCheck) - Constructor for class org.apache.flink.autoscaler.ScalingExecutor
ScalingHistoryUtils - Class in org.apache.flink.autoscaler.metrics: The utils for scaling history.
ScalingHistoryUtils() - Constructor for class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
scalingInProgress() - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus: Deprecated.
ScalingMetric - Enum in org.apache.flink.autoscaler.metrics: Supported scaling metrics.
ScalingMetricCollector<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler: Metric collector using flink rest api.
ScalingMetricCollector() - Constructor for class org.apache.flink.autoscaler.ScalingMetricCollector
ScalingMetricEvaluator - Class in org.apache.flink.autoscaler: Job scaling evaluator for autoscaler.
ScalingMetricEvaluator() - Constructor for class org.apache.flink.autoscaler.ScalingMetricEvaluator
ScalingMetrics - Class in org.apache.flink.autoscaler.metrics: Utilities for computing scaling metrics based on Flink metrics.
ScalingMetrics() - Constructor for class org.apache.flink.autoscaler.metrics.ScalingMetrics
ScalingRealizer<KEY,Context extends JobAutoScalerContext<KEY>> - Interface in org.apache.flink.autoscaler.realizer: The Scaling Realizer is responsible for applying scaling actions, i.e.
ScalingRecord - Class in org.apache.flink.autoscaler: Class for tracking scaling details, including time it took for the job to transition to the target parallelism.
ScalingRecord() - Constructor for class org.apache.flink.autoscaler.ScalingRecord
scalingReport(Map<JobVertexID, ScalingSummary>, String) - Static method in interface org.apache.flink.autoscaler.event.AutoScalerEventHandler
ScalingReport - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
scalingSingleJob(Context) - Method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor
ScalingSummary - Class in org.apache.flink.autoscaler: Scaling summary returned by the ScalingMetricEvaluator.
ScalingSummary(int, int, Map<ScalingMetric, EvaluatedScalingMetric>) - Constructor for class org.apache.flink.autoscaler.ScalingSummary
ScalingTracking - Class in org.apache.flink.autoscaler: Stores rescaling related information for the job.
ScalingTracking() - Constructor for class org.apache.flink.autoscaler.ScalingTracking
SCOPE_NAMING_KUBERNETES_OPERATOR - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCE - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
SCOPE_NAMING_KUBERNETES_OPERATOR_RESOURCENS - Static variable in class org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
SECTION_ADVANCED - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
SECTION_DYNAMIC - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
SECTION_SYSTEM - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
sendResponse(ChannelHandlerContext, String) - Static method in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
serialize(ClusterHealthInfo) - Static method in class org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
serializeAndSetLastReconciledSpec(SPEC, AbstractFlinkResource<SPEC, ?>) - Method in class org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus
serializeEvaluatedMetrics(SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
serializeEvaluatedMetrics(SortedMap<Instant, CollectedMetrics>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
serializeScalingHistory(Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Static method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
serializeScalingHistory(Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
serializeScalingTracking(ScalingTracking) - Static method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
serializeScalingTracking(ScalingTracking) - Static method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
SESSION - org.apache.flink.kubernetes.operator.config.Mode
SESSION - org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
sessionClusterReady(Optional<FlinkDeployment>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
sessionContext() - Method in class org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
SessionJobReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.sessionjob: The reconciler for the FlinkSessionJob.
SessionJobReconciler(EventRecorder, StatusRecorder<FlinkSessionJob, FlinkSessionJobStatus>, JobAutoScaler<ResourceID, KubernetesJobAutoScalerContext>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
SessionObserver - Class in org.apache.flink.kubernetes.operator.observer.deployment: The observer of the Mode.SESSION cluster.
SessionObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver
SessionReconciler - Class in org.apache.flink.kubernetes.operator.reconciler.deployment: Reconciler responsible for handling the session cluster lifecycle according to the desired and current states.
SessionReconciler(EventRecorder, StatusRecorder<FlinkDeployment, FlinkDeploymentStatus>) - Constructor for class org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
setClock(Clock) - Method in class org.apache.flink.autoscaler.JobVertexScaler
setClock(Clock) - Method in class org.apache.flink.autoscaler.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, SnapshotTriggerType, CheckpointType) - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo
setTrigger(String, SnapshotTriggerType, SavepointFormatType) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo
ShipStrategy - Enum in org.apache.flink.autoscaler.topology: The ship strategy between 2 JobVertices.
shouldDrain() - Method in class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
shouldRecoverDeployment(Configuration, FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler: Checks whether the JobManager Kubernetes Deployment recovery logic should be initiated.
shouldTriggerSnapshot(AbstractFlinkResource<?, ?>, Configuration, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils: Checks whether a snapshot should be triggered based on the current status and spec, and if yes, returns the correct SnapshotTriggerType.
SHUFFLE - org.apache.flink.autoscaler.topology.ShipStrategy
Snapshot - Interface in org.apache.flink.kubernetes.operator.api.status: A common interface for Checkpoint and Savepoint.
SnapshotInfo - Interface in org.apache.flink.kubernetes.operator.api.status: Interface representing common snapshot information.
SnapshotObserver<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.observer: An observer of savepoint progress.
SnapshotObserver(EventRecorder) - Constructor for class org.apache.flink.kubernetes.operator.observer.SnapshotObserver
SnapshotStatus - Enum in org.apache.flink.kubernetes.operator.utils: Enum encapsulating the lifecycle state of a Flink snapshot.
SnapshotTriggerType - Enum in org.apache.flink.kubernetes.operator.api.status: Snapshot trigger mechanism.
SnapshotType - Enum in org.apache.flink.kubernetes.operator.reconciler: This enumeration represents the types of state snapshots that can be taken in Flink.
SnapshotUtils - Class in org.apache.flink.kubernetes.operator.utils: Savepoint utilities.
SnapshotUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.SnapshotUtils
SOURCE_TASK_NUM_RECORDS_IN - org.apache.flink.autoscaler.metrics.FlinkMetric
SOURCE_TASK_NUM_RECORDS_IN_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric
SOURCE_TASK_NUM_RECORDS_OUT - org.apache.flink.autoscaler.metrics.FlinkMetric
SOURCE_TASK_NUM_RECORDS_OUT_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric
SpecChanged - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
SpecDiff - Annotation Type in org.apache.flink.kubernetes.operator.api.diff: Spec diff annotation.
SpecDiff.Config - Annotation Type in org.apache.flink.kubernetes.operator.api.diff: Spec diff config annotation.
SpecDiff.Entry - Annotation Type in org.apache.flink.kubernetes.operator.api.diff: Spec diff config annotation entry.
SpecUtils - Class in org.apache.flink.kubernetes.operator.api.utils: Spec utilities.
SpecUtils() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.SpecUtils
SpecWithMeta<T extends AbstractFlinkSpec> - Class in org.apache.flink.kubernetes.operator.api.utils: Utility class for encapsulating Kubernetes resource spec and meta fields during serialization.
SpecWithMeta() - Constructor for class org.apache.flink.kubernetes.operator.api.utils.SpecWithMeta
STABILIZATION_INTERVAL - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
STABLE - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
STANDALONE - org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode: Deploys Flink on-top of kubernetes in standalone mode.
StandaloneAutoscalerEntrypoint - Class in org.apache.flink.autoscaler.standalone: The entrypoint of the standalone autoscaler.
StandaloneAutoscalerEntrypoint() - Constructor for class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint
StandaloneAutoscalerExecutor<KEY,Context extends JobAutoScalerContext<KEY>> - Class in org.apache.flink.autoscaler.standalone: The executor of the standalone autoscaler.
StandaloneAutoscalerExecutor(Configuration, JobListFetcher<KEY, Context>, AutoScalerEventHandler<KEY, Context>, JobAutoScaler<KEY, Context>) - Constructor for class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor
StandaloneFlinkService - Class in org.apache.flink.kubernetes.operator.service: Implementation of FlinkService submitting and interacting with Standalone Kubernetes Flink clusters and jobs.
StandaloneFlinkService(KubernetesClient, ArtifactManager, ExecutorService, FlinkOperatorConfiguration) - Constructor for class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
StandaloneKubernetesConfigOptionsInternal - Class in org.apache.flink.kubernetes.operator.standalone: This class holds internal configuration constants used by flink operator when deploying flink clusters in standalone mode.
StandaloneKubernetesConfigOptionsInternal() - Constructor for class org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
StandaloneKubernetesConfigOptionsInternal.ClusterMode - Enum in org.apache.flink.kubernetes.operator.standalone: The different modes that a Flink cluster can be deployed in.
StandaloneKubernetesJobManagerFactory - Class in org.apache.flink.kubernetes.operator.kubeclient.factory: Utility class for constructing all the Kubernetes for the JobManager deploying in standalone mode.
StandaloneKubernetesJobManagerFactory() - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory
StandaloneKubernetesJobManagerParameters - Class in org.apache.flink.kubernetes.operator.kubeclient.parameters: A Utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the JobManager deployment used for standalone cluster deployments.
StandaloneKubernetesJobManagerParameters(Configuration, ClusterSpecification) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
StandaloneKubernetesTaskManagerFactory - Class in org.apache.flink.kubernetes.operator.kubeclient.factory: Utility class for constructing the TaskManager Deployment when deploying in standalone mode.
StandaloneKubernetesTaskManagerFactory() - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesTaskManagerFactory
StandaloneKubernetesTaskManagerParameters - Class in org.apache.flink.kubernetes.operator.kubeclient.parameters: A utility class that helps to parse, verify and manage the Kubernetes parameters that are used for constructing the TaskManager deployment used for standalone deployments.
StandaloneKubernetesTaskManagerParameters(Configuration, ClusterSpecification) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
StandaloneKubernetesUtils - Class in org.apache.flink.kubernetes.operator.utils: Standalone Kubernetes Utils.
StandaloneKubernetesUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
start() - Method in class org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor
start() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService
STATE_STORE_TYPE - Static variable in class org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
STATELESS - org.apache.flink.kubernetes.operator.api.spec.UpgradeMode: Job is upgraded with empty state.
StateType - Enum in org.apache.flink.autoscaler.jdbc.state: The state type.
STATUS_GROUP_NAME - Static variable in class org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics
statusCache - Variable in class org.apache.flink.kubernetes.operator.utils.StatusRecorder
StatusConflictException - Exception in org.apache.flink.kubernetes.operator.exception: Exception for status updates.
StatusConflictException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.StatusConflictException
statusRecorder - Variable in class org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler
StatusRecorder<CR extends AbstractFlinkResource<?,STATUS>,STATUS extends CommonStatus<?>> - Class in org.apache.flink.kubernetes.operator.utils: Helper class for status management and updates.
StatusRecorder(MetricManager<CR>, BiConsumer<CR, STATUS>) - Constructor for class org.apache.flink.kubernetes.operator.utils.StatusRecorder
stop() - Method in class org.apache.flink.kubernetes.operator.FlinkOperator
stop() - Method in class org.apache.flink.kubernetes.operator.health.HttpBootstrap
stop() - Method in class org.apache.flink.kubernetes.operator.health.OperatorHealthService
stopAndCleanupCluster(String) - Method in class org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient
StopWithSavepointRequestBody - Class in org.apache.flink.runtime.rest.messages.job.savepoints.stop: RequestBody for stopping a job with a savepoint.
StopWithSavepointRequestBody(String, Boolean, SavepointFormatType, TriggerId) - Constructor for class org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody
storeCollectedMetrics(Context, SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
storeCollectedMetrics(Context, SortedMap<Instant, CollectedMetrics>) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
storeCollectedMetrics(Context, SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
storeCollectedMetrics(KubernetesJobAutoScalerContext, SortedMap<Instant, CollectedMetrics>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
storeConfigChanges(Context, ConfigChanges) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
storeConfigChanges(Context, ConfigChanges) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
storeConfigChanges(Context, ConfigChanges) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
storeConfigChanges(KubernetesJobAutoScalerContext, ConfigChanges) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
storeParallelismOverrides(Context, Map<String, String>) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
storeParallelismOverrides(Context, Map<String, String>) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
storeParallelismOverrides(Context, Map<String, String>) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
storeParallelismOverrides(KubernetesJobAutoScalerContext, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
storeScalingHistory(Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
storeScalingHistory(Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
storeScalingHistory(Context, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
storeScalingHistory(KubernetesJobAutoScalerContext, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
storeScalingTracking(Context, ScalingTracking) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
storeScalingTracking(Context, ScalingTracking) - Method in interface org.apache.flink.autoscaler.state.AutoScalerStateStore
storeScalingTracking(Context, ScalingTracking) - Method in class org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore
storeScalingTracking(KubernetesJobAutoScalerContext, ScalingTracking) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
Submit - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
submitApplicationCluster(JobSpec, Configuration, boolean) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
submitApplicationCluster(JobSpec, Configuration, boolean) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
submitClusterInternal(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
submitClusterInternal(Configuration, Mode) - Method in class org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, JobID, Configuration, String) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
submitJobToSessionCluster(ObjectMeta, FlinkSessionJobSpec, JobID, Configuration, String) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
submitSessionCluster(Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
submitSessionCluster(Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
SUCCEEDED - org.apache.flink.kubernetes.operator.utils.SnapshotStatus: Snapshot is completed successfully.
Suspended - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
SUSPENDED - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
SUSPENDED - org.apache.flink.kubernetes.operator.api.spec.JobState: Processing is suspended with the intention of continuing later.
synchronizedCounter(Counter) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
SynchronizedCounter(Counter) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter
SynchronizedHistogram(Histogram) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram
synchronizedMeterView(MeterView) - Static method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
SynchronizedMeterView(MeterView) - Constructor for class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView

T

TARGET_DATA_RATE - org.apache.flink.autoscaler.metrics.ScalingMetric: Target processing rate of operators as derived from source inputs (records/sec).
TARGET_UTILIZATION - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
TARGET_UTILIZATION_BOUNDARY - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
TASKMANAGER_ENTRYPOINT_ARG - Static variable in class org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator
TaskManagerInfo - Class in org.apache.flink.kubernetes.operator.api.status: Last observed status of the Flink job within an application deployment.
TaskManagerInfo() - Constructor for class org.apache.flink.kubernetes.operator.api.status.TaskManagerInfo
TaskManagerSpec - Class in org.apache.flink.kubernetes.operator.api.spec: TaskManager spec.
TaskManagerSpec() - Constructor for class org.apache.flink.kubernetes.operator.api.spec.TaskManagerSpec
timeControllerExecution(Metrics.ControllerExecution<T>) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics
to - Variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
toErrorStatusUpdateControl(FlinkResourceContext<R>, Exception, StatusRecorder<R, STATUS>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Update the resource error status and metrics when the operator encountered an exception during reconciliation.
toString() - Method in class org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult
toString() - Method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceView
toString() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
toString() - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesResource
TOTAL_GC_TIME_PER_SEC - org.apache.flink.autoscaler.metrics.FlinkMetric
toUpdateControl(FlinkOperatorConfiguration, R, R, boolean) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
TRACKED_RESTART_TIME_LIMIT - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
TRACKED_TRANSITIONS - Static variable in class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics
Transition() - Constructor for class org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
triggerCheckpoint(String, SnapshotTriggerType, CheckpointInfo, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
triggerCheckpoint(String, SnapshotTriggerType, CheckpointInfo, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEvent(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEventOnce(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEventOnce(AbstractFlinkResource<?, ?>, EventRecorder.Type, EventRecorder.Reason, String, EventRecorder.Component, String, KubernetesClient) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEventWithInterval(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient, Duration) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerEventWithLabels(AbstractFlinkResource<?, ?>, EventRecorder.Type, String, String, EventRecorder.Component, String, KubernetesClient, Duration, Predicate<Map<String, String>>, Map<String, String>) - Method in class org.apache.flink.kubernetes.operator.utils.EventRecorder
triggerSavepoint(String, SnapshotTriggerType, SavepointInfo, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
triggerSavepoint(String, SnapshotTriggerType, SavepointInfo, Configuration) - Method in interface org.apache.flink.kubernetes.operator.service.FlinkService
triggerSnapshotIfNeeded(FlinkService, AbstractFlinkResource<?, ?>, Configuration, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.utils.SnapshotUtils: Triggers any pending manual or periodic snapshots and updates the status accordingly.
trimHistoryToMaxCmSize(KubernetesJobAutoScalerContext) - Method in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore
trimScalingHistory(Instant, Configuration, Map<JobVertexID, SortedMap<Instant, ScalingSummary>>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
TRUE_PROCESSING_RATE - org.apache.flink.autoscaler.metrics.ScalingMetric: Processing rate at full capacity (records/sec).
tryRelease(double, double) - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
tryReserve(double, MemorySize) - Method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceView
tryReserve(double, MemorySize) - Method in class org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
trySchedule(int, int, double, MemorySize) - Method in class org.apache.flink.autoscaler.resources.NoopResourceCheck
trySchedule(int, int, double, MemorySize) - Method in interface org.apache.flink.autoscaler.resources.ResourceCheck: Simulates scheduling the provided number of TaskManager instances.
trySchedule(int, int, double, MemorySize) - Method in class org.apache.flink.kubernetes.operator.resources.ClusterResourceManager
tuneTaskManagerMemory(JobAutoScalerContext<?>, EvaluatedMetrics, JobTopology, Map<JobVertexID, ScalingSummary>, AutoScalerEventHandler) - Static method in class org.apache.flink.autoscaler.tuning.MemoryTuning: Emits a Configuration which contains overrides for the current configuration.
type() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry

U

UNKNOWN - org.apache.flink.autoscaler.topology.ShipStrategy
UNKNOWN - org.apache.flink.kubernetes.operator.api.status.CheckpointType: Checkpoint format unknown, if the checkpoint was not triggered by the operator.
UNKNOWN - org.apache.flink.kubernetes.operator.api.status.SavepointFormatType: Savepoint format unknown, if the savepoint was not triggered by the operator.
UNKNOWN - org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType: Snapshot trigger mechanism unknown, such as savepoint retrieved directly from Flink job.
UnknownJobException - Exception in org.apache.flink.kubernetes.operator.exception: Exception to signal unrecognized job found.
UnknownJobException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException
UnknownJobException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException
UnknownJobException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.UnknownJobException
UnsupportedFlinkVersion - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
update() - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView
update(long) - Method in class org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram
updateData(String, List<StateType>, Map<StateType, String>) - Method in class org.apache.flink.autoscaler.jdbc.state.JdbcStateInteractor
updateDefaultConfig(Configuration) - Method in class org.apache.flink.kubernetes.operator.config.FlinkConfigManager: Update the base configuration for the operator.
updateErrorStatus(FlinkDeployment, Context<FlinkDeployment>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController
updateErrorStatus(FlinkSessionJob, Context<FlinkSessionJob>, Exception) - Method in class org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController
updateEvent(long, String, int) - Method in class org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
updateFlinkResourceException(Throwable, R, FlinkOperatorConfiguration) - Static method in class org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
updateForReconciliationError(FlinkResourceContext, Throwable) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
updateIngressRules(ObjectMeta, FlinkDeploymentSpec, Configuration, KubernetesClient) - Static method in class org.apache.flink.kubernetes.operator.utils.IngressUtils
updateLastCheckpoint(Checkpoint) - Method in class org.apache.flink.kubernetes.operator.api.status.CheckpointInfo: Update last checkpoint info.
updateLastReconciledSnapshotTriggerNonce(SnapshotInfo, AbstractFlinkResource<SPEC, ?>, SnapshotType) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
updateLastSavepoint(Savepoint) - Method in class org.apache.flink.kubernetes.operator.api.status.SavepointInfo: Update last savepoint info and add the savepoint to the history if it isn't already the most recent savepoint.
updateMaxParallelism(int) - Method in class org.apache.flink.autoscaler.topology.VertexInfo
updateMaxParallelism(JobVertexID, int) - Method in class org.apache.flink.autoscaler.topology.JobTopology
updateMetrics(Context, AutoScalerStateStore<KEY, Context>) - Method in class org.apache.flink.autoscaler.ScalingMetricCollector
updateReconciliationMetadata(AbstractFlinkResource<SPEC, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
updateStatusAfterClusterDeletion(FlinkDeploymentStatus) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
updateStatusBeforeDeploymentAttempt(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Update status before deployment attempt of a new resource spec.
updateStatusForAlreadyUpgraded(AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Updates status in cases where a previously successful deployment wasn't recorded for any reason.
updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
updateStatusForDeployedSpec(AbstractFlinkResource<SPEC, ?>, Configuration, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils: Update status after successful deployment of a new resource spec.
updateStatusForSpecReconciliation(AbstractFlinkResource<SPEC, ?>, JobState, Configuration, boolean, Clock) - Static method in class org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
updateStatusFromCache(CR) - Method in class org.apache.flink.kubernetes.operator.utils.StatusRecorder: Update the custom resource status based on the in-memory cached to ensure that any status updates that we made previously are always visible in the reconciliation loop.
updateVertexList(AutoScalerStateStore<KEY, Context>, Context, Instant, Set<JobVertexID>) - Static method in class org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
updateVertexResources(RestClusterClient<String>, AbstractFlinkResource<?, ?>, Map<JobVertexID, JobVertexResourceRequirements>) - Method in class org.apache.flink.kubernetes.operator.service.NativeFlinkService
UPGRADE - org.apache.flink.kubernetes.operator.api.diff.DiffType: Upgradable spec change.
UPGRADE - org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType: Snapshot triggered during stateful upgrade.
UpgradeMode - Enum in org.apache.flink.kubernetes.operator.api.spec: Enum to control Flink job upgrade behavior.
UPGRADING - org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
UPGRADING - org.apache.flink.kubernetes.operator.api.status.ReconciliationState: The spec is being upgraded.
uploadJar(ObjectMeta, FlinkSessionJobSpec, Configuration) - Method in class org.apache.flink.kubernetes.operator.service.AbstractFlinkService
URL - Static variable in class org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders
UserLibMountDecorator - Class in org.apache.flink.kubernetes.operator.kubeclient.decorators: Mount the Flink User Lib directory to enable Flink to pick up a Jars defined in pipeline.classpaths.
UserLibMountDecorator(StandaloneKubernetesJobManagerParameters) - Constructor for class org.apache.flink.kubernetes.operator.kubeclient.decorators.UserLibMountDecorator
Utils - Class in org.apache.flink.kubernetes.operator.docs.util: Contains various shared utility functions.
Utils() - Constructor for class org.apache.flink.kubernetes.operator.docs.util.Utils

V

v1_13 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion: Deprecated.
v1_14 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion: Deprecated.
v1_15 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
v1_16 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
v1_17 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
v1_18 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
v1_19 - org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
validate(HasMetadata, Operation) - Method in class org.apache.flink.kubernetes.operator.admission.FlinkValidator
VALIDATE_REQUEST_PATH - Static variable in class org.apache.flink.kubernetes.operator.admission.AdmissionHandler
validateAutoScalerFlinkConfiguration(Map<String, String>) - Static method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator
validateDeployment(FlinkDeployment) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator
validateDeployment(FlinkDeployment) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator: Validate and return optional error.
validateExcludedPeriods(Configuration) - Static method in class org.apache.flink.autoscaler.utils.CalendarUtils
validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in class org.apache.flink.kubernetes.operator.validation.DefaultValidator
validateSessionJob(FlinkSessionJob, Optional<FlinkDeployment>) - Method in interface org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator: Validate and return optional error.
validateSupportedVersion(FlinkResourceContext<?>, EventRecorder) - Static method in class org.apache.flink.kubernetes.operator.utils.ValidatorUtils
ValidationError - org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
ValidationException - Exception in org.apache.flink.kubernetes.operator.exception: Exception to signal validation failure.
ValidationException(String) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException
ValidationException(String, Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException
ValidationException(Throwable) - Constructor for exception org.apache.flink.kubernetes.operator.exception.ValidationException
ValidatorUtils - Class in org.apache.flink.kubernetes.operator.utils: Validator utilities.
ValidatorUtils() - Constructor for class org.apache.flink.kubernetes.operator.utils.ValidatorUtils
value() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Config
value() - Method in annotation type org.apache.flink.kubernetes.operator.api.diff.SpecDiff
valueOf(String) - Static method in enum org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.jdbc.state.StateType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.metrics.FlinkMetric: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.metrics.MetricAggregator: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.metrics.ScalingMetric: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory.EventHandlerType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory.StateStoreType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.autoscaler.topology.ShipStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.JobState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.spec.UpgradeMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.CheckpointType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.ReconciliationState: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointFormatType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.config.Mode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.reconciler.SnapshotType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.flink.kubernetes.operator.utils.SnapshotStatus: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.jdbc.state.StateType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.metrics.FlinkMetric: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.metrics.MetricAggregator: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.metrics.ScalingMetric: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory.EventHandlerType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory.StateStoreType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.autoscaler.topology.ShipStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.diff.DiffType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.FlinkVersion: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.JobState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.spec.UpgradeMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.CheckpointType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.ReconciliationState: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.SavepointFormatType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.config.Mode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.health.HealthProbe: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.reconciler.SnapshotType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Component: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.EventRecorder.Type: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.flink.kubernetes.operator.utils.SnapshotStatus: Returns an array containing the constants of this enum type, in the order they are declared.
verifyOtherPropsMatch(String, JsonNode, JsonNode) - Static method in class org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
VERSION_CONF_PREFIX - Static variable in class org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
VERTEX_EXCLUDE_IDS - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
VERTEX_MAX_PARALLELISM - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
VERTEX_MIN_PARALLELISM - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
VERTEX_SCALING_HISTORY_AGE - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
VERTEX_SCALING_HISTORY_COUNT - Static variable in class org.apache.flink.autoscaler.config.AutoScalerOptions
VertexInfo - Class in org.apache.flink.autoscaler.topology: Job vertex information.
VertexInfo(JobVertexID, Map<JobVertexID, ShipStrategy>, int, int) - Constructor for class org.apache.flink.autoscaler.topology.VertexInfo
VertexInfo(JobVertexID, Map<JobVertexID, ShipStrategy>, int, int, boolean, IOMetrics) - Constructor for class org.apache.flink.autoscaler.topology.VertexInfo
VertexInfo(JobVertexID, Map<JobVertexID, ShipStrategy>, int, int, IOMetrics) - Constructor for class org.apache.flink.autoscaler.topology.VertexInfo
VertexScalingReport - Class in org.apache.flink.autoscaler.event: The scaling report of single vertex.
VertexScalingReport() - Constructor for class org.apache.flink.autoscaler.event.VertexScalingReport

W

Warning - org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type
Warning - org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
writeSpecWithMeta(AbstractFlinkSpec, AbstractFlinkResource<?, ?>) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils: Serializes the spec and custom meta information into a JSON string.
writeSpecWithMeta(AbstractFlinkSpec, ReconciliationMetadata) - Static method in class org.apache.flink.kubernetes.operator.api.utils.SpecUtils: Serializes the spec and custom meta information into a JSON string.

Y

YAML_MAPPER - Static variable in class org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore
YAML_MAPPER - Static variable in class org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore

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