Hierarchy For All Packages

Package Hierarchies:

• autoscaling,
• org.apache.flink.autoscaler,
• org.apache.flink.autoscaler.config,
• org.apache.flink.autoscaler.event,
• org.apache.flink.autoscaler.exceptions,
• org.apache.flink.autoscaler.jdbc.event,
• org.apache.flink.autoscaler.jdbc.state,
• org.apache.flink.autoscaler.metrics,
• org.apache.flink.autoscaler.realizer,
• org.apache.flink.autoscaler.resources,
• org.apache.flink.autoscaler.standalone,
• org.apache.flink.autoscaler.standalone.config,
• org.apache.flink.autoscaler.standalone.flinkcluster,
• org.apache.flink.autoscaler.standalone.realizer,
• org.apache.flink.autoscaler.standalone.utils,
• org.apache.flink.autoscaler.state,
• org.apache.flink.autoscaler.topology,
• org.apache.flink.autoscaler.tuning,
• org.apache.flink.autoscaler.utils,
• org.apache.flink.kubernetes.operator,
• org.apache.flink.kubernetes.operator.admission,
• org.apache.flink.kubernetes.operator.admission.informer,
• org.apache.flink.kubernetes.operator.admission.mutator,
• org.apache.flink.kubernetes.operator.api,
• org.apache.flink.kubernetes.operator.api.diff,
• org.apache.flink.kubernetes.operator.api.docs,
• org.apache.flink.kubernetes.operator.api.lifecycle,
• org.apache.flink.kubernetes.operator.api.listener,
• org.apache.flink.kubernetes.operator.api.reconciler,
• org.apache.flink.kubernetes.operator.api.spec,
• org.apache.flink.kubernetes.operator.api.status,
• org.apache.flink.kubernetes.operator.api.utils,
• org.apache.flink.kubernetes.operator.api.validation,
• org.apache.flink.kubernetes.operator.artifact,
• org.apache.flink.kubernetes.operator.autoscaler,
• org.apache.flink.kubernetes.operator.autoscaler.state,
• org.apache.flink.kubernetes.operator.config,
• org.apache.flink.kubernetes.operator.controller,
• org.apache.flink.kubernetes.operator.docs.configuration,
• org.apache.flink.kubernetes.operator.docs.util,
• org.apache.flink.kubernetes.operator.exception,
• org.apache.flink.kubernetes.operator.fs,
• org.apache.flink.kubernetes.operator.health,
• org.apache.flink.kubernetes.operator.kubeclient,
• org.apache.flink.kubernetes.operator.kubeclient.decorators,
• org.apache.flink.kubernetes.operator.kubeclient.factory,
• org.apache.flink.kubernetes.operator.kubeclient.parameters,
• org.apache.flink.kubernetes.operator.listener,
• org.apache.flink.kubernetes.operator.metrics,
• org.apache.flink.kubernetes.operator.metrics.lifecycle,
• org.apache.flink.kubernetes.operator.mutator,
• org.apache.flink.kubernetes.operator.observer,
• org.apache.flink.kubernetes.operator.observer.deployment,
• org.apache.flink.kubernetes.operator.observer.sessionjob,
• org.apache.flink.kubernetes.operator.observer.snapshot,
• org.apache.flink.kubernetes.operator.reconciler,
• org.apache.flink.kubernetes.operator.reconciler.deployment,
• org.apache.flink.kubernetes.operator.reconciler.diff,
• org.apache.flink.kubernetes.operator.reconciler.sessionjob,
• org.apache.flink.kubernetes.operator.reconciler.snapshot,
• org.apache.flink.kubernetes.operator.resources,
• org.apache.flink.kubernetes.operator.service,
• org.apache.flink.kubernetes.operator.ssl,
• org.apache.flink.kubernetes.operator.standalone,
• org.apache.flink.kubernetes.operator.utils,
• org.apache.flink.kubernetes.operator.validation,
• org.apache.flink.runtime.rest.messages.job,
• org.apache.flink.runtime.rest.messages.job.metrics,
• org.apache.flink.runtime.rest.messages.json

Class Hierarchy

• java.lang.Object
  • org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<CR> (implements org.apache.flink.kubernetes.operator.observer.Observer<CR>)
    • org.apache.flink.kubernetes.operator.observer.deployment.AbstractFlinkDeploymentObserver
      • org.apache.flink.kubernetes.operator.observer.deployment.ApplicationObserver
      • org.apache.flink.kubernetes.operator.observer.deployment.SessionObserver
    • org.apache.flink.kubernetes.operator.observer.sessionjob.FlinkSessionJobObserver
  • org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractFlinkResourceReconciler<CR,SPEC,STATUS> (implements org.apache.flink.kubernetes.operator.reconciler.Reconciler<CR>)
    • org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler<CR,SPEC,STATUS>
      • org.apache.flink.kubernetes.operator.reconciler.deployment.ApplicationReconciler
      • org.apache.flink.kubernetes.operator.reconciler.sessionjob.SessionJobReconciler
    • org.apache.flink.kubernetes.operator.reconciler.deployment.SessionReconciler
  • org.apache.flink.kubernetes.operator.service.AbstractFlinkService (implements org.apache.flink.kubernetes.operator.service.FlinkService)
    • org.apache.flink.kubernetes.operator.service.NativeFlinkService
    • org.apache.flink.kubernetes.operator.service.StandaloneFlinkService
  • org.apache.flink.kubernetes.operator.api.spec.AbstractFlinkSpec (implements org.apache.flink.kubernetes.operator.api.diff.Diffable<T>)
    • org.apache.flink.kubernetes.operator.api.spec.FlinkDeploymentSpec
    • org.apache.flink.kubernetes.operator.api.spec.FlinkSessionJobSpec
  • org.apache.flink.kubernetes.operator.reconciler.deployment.AbstractJobReconciler.JobUpgrade
  • org.apache.flink.kubernetes.kubeclient.parameters.AbstractKubernetesParameters (implements org.apache.flink.kubernetes.kubeclient.parameters.KubernetesParameters)
    • org.apache.flink.kubernetes.kubeclient.parameters.KubernetesJobManagerParameters
      • org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesJobManagerParameters
    • org.apache.flink.kubernetes.operator.kubeclient.parameters.StandaloneKubernetesTaskManagerParameters
  • org.apache.flink.kubernetes.kubeclient.decorators.AbstractKubernetesStepDecorator (implements org.apache.flink.kubernetes.kubeclient.decorators.KubernetesStepDecorator)
    • org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneJobManagerDecorator
    • org.apache.flink.kubernetes.operator.kubeclient.decorators.CmdStandaloneTaskManagerDecorator
    • org.apache.flink.kubernetes.operator.kubeclient.decorators.InitStandaloneTaskManagerDecorator
    • org.apache.flink.kubernetes.operator.kubeclient.decorators.UserLibMountDecorator
  • org.apache.flink.runtime.metrics.groups.AbstractMetricGroup<A> (implements org.apache.flink.metrics.MetricGroup)
    • org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricGroup
    • org.apache.flink.kubernetes.operator.metrics.KubernetesResourceMetricGroup
    • org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceMetricGroup
  • org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric
  • org.apache.flink.kubernetes.operator.artifact.ArtifactManager
  • org.apache.flink.kubernetes.operator.listener.AuditUtils
  • org.apache.flink.autoscaler.jdbc.event.AutoScalerEvent
  • org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory
  • org.apache.flink.autoscaler.event.AutoscalerEventUtils
  • org.apache.flink.kubernetes.operator.autoscaler.AutoscalerFactory
  • org.apache.flink.autoscaler.metrics.AutoscalerFlinkMetrics
  • org.apache.flink.autoscaler.config.AutoScalerOptions
  • org.apache.flink.autoscaler.standalone.config.AutoscalerStandaloneOptions
  • org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory
  • org.apache.flink.autoscaler.utils.AutoScalerUtils
  • autoscaling.AutoscalingExample
  • org.apache.flink.autoscaler.utils.CalendarUtils
  • org.apache.flink.kubernetes.operator.health.CanaryResourceManager<CR>
  • org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter (implements org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler)
    • org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter (implements org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler)
      • org.apache.flink.shaded.netty4.io.netty.channel.SimpleChannelInboundHandler<I>
        • org.apache.flink.kubernetes.operator.admission.AdmissionHandler
        • org.apache.flink.kubernetes.operator.health.OperatorHealthHandler
  • org.apache.flink.kubernetes.operator.api.status.Checkpoint (implements org.apache.flink.kubernetes.operator.api.status.Snapshot)
  • org.apache.flink.kubernetes.operator.observer.CheckpointFetchResult
  • org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper (implements org.apache.flink.runtime.rest.messages.ResponseBody)
  • org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.CompletedCheckpointInfo
  • org.apache.flink.kubernetes.operator.service.CheckpointHistoryWrapper.PendingCheckpointInfo
  • org.apache.flink.kubernetes.operator.api.status.CheckpointInfo (implements org.apache.flink.kubernetes.operator.api.status.SnapshotInfo)
  • org.apache.flink.kubernetes.operator.api.spec.CheckpointSpec
  • org.apache.flink.kubernetes.operator.observer.CheckpointStatsResult
  • org.apache.flink.kubernetes.operator.observer.ClusterHealthEvaluator
  • org.apache.flink.kubernetes.operator.health.ClusterHealthInfo
  • org.apache.flink.kubernetes.operator.observer.ClusterHealthObserver
  • org.apache.flink.kubernetes.operator.resources.ClusterResourceManager (implements org.apache.flink.autoscaler.resources.ResourceCheck)
  • org.apache.flink.kubernetes.operator.resources.ClusterResourceView
  • org.apache.flink.autoscaler.metrics.CollectedMetricHistory
  • org.apache.flink.autoscaler.metrics.CollectedMetrics
  • org.apache.flink.kubernetes.operator.api.status.CommonStatus<SPEC>
    • org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus
    • org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus
  • org.apache.flink.autoscaler.tuning.ConfigChanges
  • org.apache.flink.kubernetes.operator.autoscaler.state.ConfigMapStore
  • org.apache.flink.kubernetes.operator.docs.configuration.ConfigOptionsDocGenerator
  • org.apache.flink.kubernetes.operator.utils.ConfigOptionUtils
  • org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker
  • org.apache.flink.kubernetes.operator.api.CrdConstants
  • org.apache.flink.kubernetes.operator.api.docs.CrdReferenceDoclet (implements jdk.javadoc.doclet.Doclet)
  • org.apache.flink.kubernetes.operator.service.CustomCheckpointingStatisticsHeaders (implements org.apache.flink.runtime.rest.messages.RuntimeMessageHeaders<R,P,M>)
  • org.apache.flink.kubernetes.operator.service.CustomDashboardConfiguration (implements org.apache.flink.runtime.rest.messages.ResponseBody)
  • org.apache.flink.kubernetes.operator.service.CustomDashboardConfigurationHeaders (implements org.apache.flink.runtime.rest.messages.RuntimeMessageHeaders<R,P,M>)
  • io.fabric8.kubernetes.client.CustomResource<S,T> (implements io.fabric8.kubernetes.api.model.HasMetadata)
    • org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<SPEC,STATUS> (implements io.fabric8.kubernetes.api.model.Namespaced)
      • org.apache.flink.kubernetes.operator.api.FlinkDeployment (implements io.fabric8.kubernetes.api.model.Namespaced)
      • org.apache.flink.kubernetes.operator.api.FlinkSessionJob (implements io.fabric8.kubernetes.api.model.Namespaced)
    • org.apache.flink.kubernetes.operator.api.FlinkStateSnapshot (implements io.fabric8.kubernetes.api.model.Namespaced)
  • org.apache.flink.autoscaler.utils.DateTimeUtils
  • org.apache.flink.kubernetes.operator.mutator.DefaultFlinkMutator (implements org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator)
  • io.fabric8.kubernetes.api.model.DefaultKubernetesResourceList<T> (implements io.fabric8.kubernetes.api.model.KubernetesResource, io.fabric8.kubernetes.api.model.KubernetesResourceList<E>)
    • org.apache.flink.kubernetes.operator.api.FlinkDeploymentList
    • org.apache.flink.kubernetes.operator.api.FlinkSessionJobList
  • org.apache.flink.kubernetes.operator.admission.mutator.DefaultRequestMutator<T> (implements io.javaoperatorsdk.webhook.admission.AdmissionRequestHandler)
  • org.apache.flink.kubernetes.operator.validation.DefaultValidator (implements org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator)
  • org.apache.flink.autoscaler.DelayedScaleDown
  • org.apache.flink.kubernetes.operator.reconciler.diff.Diff<T>
  • org.apache.flink.kubernetes.operator.reconciler.diff.DiffBuilder<T> (implements org.apache.commons.lang3.builder.Builder<T>)
  • org.apache.flink.kubernetes.operator.reconciler.diff.DiffResult<T>
  • org.apache.flink.autoscaler.metrics.Edge
  • org.apache.flink.kubernetes.operator.utils.EnvUtils
  • org.apache.flink.autoscaler.metrics.EvaluatedMetrics
  • org.apache.flink.autoscaler.metrics.EvaluatedScalingMetric
  • org.apache.flink.kubernetes.operator.utils.EventRecorder
  • org.apache.flink.kubernetes.operator.utils.EventSourceUtils
  • org.apache.flink.kubernetes.operator.utils.EventUtils
  • org.apache.flink.kubernetes.kubeclient.Fabric8FlinkKubeClient (implements org.apache.flink.kubernetes.kubeclient.FlinkKubeClient)
    • org.apache.flink.kubernetes.operator.kubeclient.Fabric8FlinkStandaloneKubeClient (implements org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient)
  • org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher (implements org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher)
  • org.apache.flink.autoscaler.standalone.flinkcluster.FlinkClusterJobListFetcher (implements org.apache.flink.autoscaler.standalone.JobListFetcher<KEY,Context>)
  • org.apache.flink.kubernetes.operator.config.FlinkConfigBuilder
  • org.apache.flink.kubernetes.operator.config.FlinkConfigManager
  • org.apache.flink.kubernetes.operator.controller.FlinkDeploymentController (implements io.javaoperatorsdk.operator.api.reconciler.Cleaner<P>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<P>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<P>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<R>)
  • org.apache.flink.kubernetes.operator.metrics.FlinkDeploymentMetrics (implements org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics<CR>)
  • org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory
  • org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator (implements io.javaoperatorsdk.webhook.admission.mutation.Mutator<T>)
  • org.apache.flink.kubernetes.operator.FlinkOperator
  • org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration
  • org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook
  • org.apache.flink.kubernetes.operator.controller.FlinkResourceContext<CR>
    • org.apache.flink.kubernetes.operator.controller.FlinkDeploymentContext
    • org.apache.flink.kubernetes.operator.controller.FlinkSessionJobContext
  • org.apache.flink.kubernetes.operator.service.FlinkResourceContextFactory
  • org.apache.flink.kubernetes.operator.exception.FlinkResourceException
  • org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
  • org.apache.flink.kubernetes.operator.api.utils.FlinkResourceUtils
  • org.apache.flink.kubernetes.operator.service.FlinkService.CancelResult
  • org.apache.flink.kubernetes.operator.controller.FlinkSessionJobController (implements io.javaoperatorsdk.operator.api.reconciler.Cleaner<P>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<P>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<P>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<R>)
  • org.apache.flink.kubernetes.operator.metrics.FlinkSessionJobMetrics (implements org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics<CR>)
  • org.apache.flink.kubernetes.operator.controller.FlinkStateSnapshotContext
  • org.apache.flink.kubernetes.operator.controller.FlinkStateSnapshotController (implements io.javaoperatorsdk.operator.api.reconciler.Cleaner<P>, io.javaoperatorsdk.operator.api.reconciler.ErrorStatusHandler<P>, io.javaoperatorsdk.operator.api.reconciler.EventSourceInitializer<P>, io.javaoperatorsdk.operator.api.reconciler.Reconciler<R>)
  • org.apache.flink.kubernetes.operator.metrics.FlinkStateSnapshotMetrics (implements org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics<CR>)
  • org.apache.flink.kubernetes.operator.api.spec.FlinkStateSnapshotSpec (implements org.apache.flink.kubernetes.operator.api.diff.Diffable<T>)
  • org.apache.flink.kubernetes.operator.api.status.FlinkStateSnapshotStatus (implements org.apache.flink.kubernetes.operator.api.diff.Diffable<T>)
  • org.apache.flink.kubernetes.operator.utils.FlinkStateSnapshotUtils
  • org.apache.flink.kubernetes.operator.utils.FlinkUtils
  • org.apache.flink.kubernetes.operator.admission.FlinkValidator (implements io.javaoperatorsdk.webhook.admission.validation.Validator<T>)
  • org.apache.flink.autoscaler.standalone.utils.HikariJDBCUtil
  • org.apache.flink.kubernetes.operator.artifact.HttpArtifactFetcher (implements org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher)
  • org.apache.flink.kubernetes.operator.health.HttpBootstrap
  • org.apache.flink.kubernetes.operator.health.InformerHealthSummary
  • org.apache.flink.kubernetes.operator.health.InformerIdentifier
  • org.apache.flink.kubernetes.operator.admission.informer.InformerManager
  • org.apache.flink.kubernetes.operator.api.spec.IngressSpec
  • org.apache.flink.kubernetes.operator.utils.IngressUtils
  • org.apache.flink.autoscaler.state.InMemoryAutoScalerStateStore<KEY,Context> (implements org.apache.flink.autoscaler.state.AutoScalerStateStore<KEY,Context>)
  • org.apache.flink.autoscaler.topology.IOMetrics
  • org.apache.flink.runtime.rest.messages.job.metrics.IOMetricsInfo
  • org.apache.flink.autoscaler.jdbc.event.JdbcAutoScalerEventHandler<KEY,Context> (implements org.apache.flink.autoscaler.event.AutoScalerEventHandler<KEY,Context>)
  • org.apache.flink.autoscaler.jdbc.state.JdbcAutoScalerStateStore<KEY,Context> (implements org.apache.flink.autoscaler.state.AutoScalerStateStore<KEY,Context>)
  • org.apache.flink.autoscaler.jdbc.event.JdbcEventInteractor
  • org.apache.flink.autoscaler.jdbc.state.JdbcStateInteractor
  • org.apache.flink.autoscaler.jdbc.state.JdbcStateStore
  • org.apache.flink.autoscaler.JobAutoScalerContext<KEY>
    • org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext
  • org.apache.flink.autoscaler.JobAutoScalerImpl<KEY,Context> (implements org.apache.flink.autoscaler.JobAutoScaler<KEY,Context>)
  • org.apache.flink.runtime.rest.messages.job.JobDetailsInfo (implements org.apache.flink.runtime.rest.messages.ResponseBody)
  • org.apache.flink.runtime.rest.messages.job.JobDetailsInfo.JobVertexDetailsInfo
  • org.apache.flink.kubernetes.operator.api.spec.JobManagerSpec
  • org.apache.flink.kubernetes.operator.api.spec.JobReference
  • org.apache.flink.kubernetes.operator.api.spec.JobSpec (implements org.apache.flink.kubernetes.operator.api.diff.Diffable<T>)
  • org.apache.flink.autoscaler.jdbc.state.JobStateView
  • org.apache.flink.kubernetes.operator.api.status.JobStatus
  • org.apache.flink.kubernetes.operator.observer.JobStatusObserver<R>
  • org.apache.flink.autoscaler.utils.JobStatusUtils
  • org.apache.flink.autoscaler.topology.JobTopology
  • org.apache.flink.autoscaler.JobVertexScaler<KEY,Context>
  • org.apache.flink.autoscaler.JobVertexScaler.ParallelismChange
  • org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonDeserializer<T> (implements org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.NullValueProvider)
    • org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.std.StdDeserializer<T> (implements java.io.Serializable, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.deser.ValueInstantiator.Gettable)
      • org.apache.flink.runtime.rest.messages.json.SlotSharingGroupIDDeserializer
  • org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonSerializer<T> (implements org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.jsonFormatVisitors.JsonFormatVisitable)
    • org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ser.std.StdSerializer<T> (implements org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.jsonFormatVisitors.JsonFormatVisitable, org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.jsonschema.SchemaAware, java.io.Serializable)
      • org.apache.flink.runtime.rest.messages.json.SlotSharingGroupIDSerializer
  • org.apache.flink.kubernetes.operator.autoscaler.KubernetesAutoScalerEventHandler (implements org.apache.flink.autoscaler.event.AutoScalerEventHandler<KEY,Context>)
  • org.apache.flink.kubernetes.operator.autoscaler.state.KubernetesAutoScalerStateStore (implements org.apache.flink.autoscaler.state.AutoScalerStateStore<KEY,Context>)
  • org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics (implements io.fabric8.kubernetes.client.http.Interceptor)
  • org.apache.flink.kubernetes.operator.utils.KubernetesClientUtils
  • org.apache.flink.kubernetes.KubernetesClusterDescriptor (implements org.apache.flink.client.deployment.ClusterDescriptor<T>)
    • org.apache.flink.kubernetes.operator.standalone.KubernetesStandaloneClusterDescriptor
  • org.apache.flink.kubernetes.operator.resources.KubernetesNodeResourceInfo
  • org.apache.flink.kubernetes.operator.config.KubernetesOperatorConfigOptions
  • org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
  • org.apache.flink.kubernetes.operator.resources.KubernetesResource
  • org.apache.flink.kubernetes.operator.autoscaler.KubernetesScalingRealizer (implements org.apache.flink.autoscaler.realizer.ScalingRealizer<KEY,Context>)
  • org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics<CR> (implements org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics<CR>)
  • org.apache.flink.kubernetes.operator.metrics.lifecycle.LifecycleMetrics.Transition
  • org.apache.flink.kubernetes.operator.listener.ListenerUtils
  • autoscaling.LoadSimulationPipeline
  • org.apache.flink.autoscaler.event.LoggingEventHandler<KEY,Context> (implements org.apache.flink.autoscaler.event.AutoScalerEventHandler<KEY,Context>)
  • org.apache.flink.autoscaler.tuning.MemoryBudget
  • org.apache.flink.autoscaler.tuning.MemoryScaling
  • org.apache.flink.autoscaler.tuning.MemoryTuning
  • org.apache.flink.kubernetes.operator.metrics.MetricManager<CR>
  • org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.Module (implements org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.Versioned)
    • org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.module.SimpleModule (implements java.io.Serializable)
      • org.apache.flink.autoscaler.utils.AutoScalerSerDeModule
  • org.apache.flink.kubernetes.operator.utils.MutatorUtils
  • org.apache.flink.autoscaler.NoopJobAutoscaler<KEY,Context> (implements org.apache.flink.autoscaler.JobAutoScaler<KEY,Context>)
  • org.apache.flink.autoscaler.resources.NoopResourceCheck (implements org.apache.flink.autoscaler.resources.ResourceCheck)
  • org.apache.flink.kubernetes.operator.health.OperatorHealthService
  • org.apache.flink.kubernetes.operator.metrics.OperatorJosdkMetrics (implements io.javaoperatorsdk.operator.api.monitoring.Metrics)
  • org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils
  • org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedCounter (implements org.apache.flink.metrics.Counter)
  • org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedHistogram (implements org.apache.flink.metrics.Histogram)
  • org.apache.flink.kubernetes.operator.metrics.OperatorMetricUtils.SynchronizedMeterView (implements org.apache.flink.metrics.Meter, org.apache.flink.metrics.View)
  • org.apache.flink.kubernetes.operator.reconciler.deployment.ReconcilerFactory
  • org.apache.flink.kubernetes.operator.api.reconciler.ReconciliationMetadata
  • org.apache.flink.kubernetes.operator.api.status.ReconciliationStatus<SPEC>
    • org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentReconciliationStatus
    • org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobReconciliationStatus
  • org.apache.flink.kubernetes.operator.reconciler.ReconciliationUtils
  • org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder<T> (implements org.apache.commons.lang3.builder.Builder<T>)
  • org.apache.flink.autoscaler.standalone.realizer.RescaleApiScalingRealizer<KEY,Context> (implements org.apache.flink.autoscaler.realizer.ScalingRealizer<KEY,Context>)
  • org.apache.flink.kubernetes.operator.api.spec.Resource
  • org.apache.flink.autoscaler.utils.ResourceCheckUtils
  • org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
  • org.apache.flink.kubernetes.operator.api.status.Savepoint (implements org.apache.flink.kubernetes.operator.api.status.Snapshot)
  • org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
  • org.apache.flink.kubernetes.operator.api.status.SavepointInfo (implements org.apache.flink.kubernetes.operator.api.status.SnapshotInfo)
  • org.apache.flink.kubernetes.operator.api.spec.SavepointSpec
  • org.apache.flink.autoscaler.ScalingExecutor<KEY,Context>
  • org.apache.flink.autoscaler.metrics.ScalingHistoryUtils
  • org.apache.flink.autoscaler.ScalingMetricCollector<KEY,Context>
    • org.apache.flink.autoscaler.RestApiMetricsCollector<KEY,Context>
  • org.apache.flink.autoscaler.ScalingMetricEvaluator
  • org.apache.flink.autoscaler.metrics.ScalingMetrics
  • org.apache.flink.autoscaler.ScalingRecord
  • org.apache.flink.autoscaler.ScalingSummary
  • org.apache.flink.autoscaler.ScalingTracking
  • org.apache.flink.runtime.metrics.scope.ScopeFormat
    • org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorScopeFormat
    • org.apache.flink.kubernetes.operator.metrics.KubernetesResourceNamespaceScopeFormat
    • org.apache.flink.kubernetes.operator.metrics.KubernetesResourceScopeFormat
  • org.apache.flink.runtime.rest.messages.json.SlotSharingGroupIdConverter
  • org.apache.flink.kubernetes.operator.observer.SnapshotObserver<CR,STATUS>
  • org.apache.flink.kubernetes.operator.reconciler.SnapshotTriggerTimestampStore
  • org.apache.flink.kubernetes.operator.utils.SnapshotUtils
  • org.apache.flink.kubernetes.operator.api.utils.SpecUtils
  • org.apache.flink.kubernetes.operator.api.utils.SpecWithMeta<T>
  • org.apache.flink.shaded.netty4.io.netty.handler.ssl.SslContext
    • org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
  • org.apache.flink.autoscaler.standalone.StandaloneAutoscalerEntrypoint
  • org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor<KEY,Context> (implements java.io.Closeable)
  • org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal
  • org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesJobManagerFactory
  • org.apache.flink.kubernetes.operator.kubeclient.factory.StandaloneKubernetesTaskManagerFactory
  • org.apache.flink.kubernetes.operator.utils.StandaloneKubernetesUtils
  • org.apache.flink.kubernetes.operator.observer.snapshot.StateSnapshotObserver
  • org.apache.flink.kubernetes.operator.reconciler.snapshot.StateSnapshotReconciler
  • org.apache.flink.kubernetes.operator.utils.StatusRecorder<CR,STATUS>
  • org.apache.flink.kubernetes.operator.api.status.TaskManagerInfo
  • org.apache.flink.kubernetes.operator.api.spec.TaskManagerSpec (implements org.apache.flink.kubernetes.operator.api.diff.Diffable<T>)
  • java.lang.Thread (implements java.lang.Runnable)
    • org.apache.flink.kubernetes.operator.fs.FileSystemWatchService
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.flink.kubernetes.operator.api.validation.CrdCompatibilityChecker.CompatibilityError
        • org.apache.flink.kubernetes.operator.exception.DeploymentFailedException
        • org.apache.flink.autoscaler.metrics.MetricNotFoundException
        • org.apache.flink.kubernetes.operator.exception.MissingJobManagerException
        • org.apache.flink.autoscaler.exceptions.NotReadyException
        • org.apache.flink.kubernetes.operator.exception.ReconciliationException
        • org.apache.flink.kubernetes.operator.exception.StatusConflictException
        • org.apache.flink.kubernetes.operator.exception.UpgradeFailureException
        • org.apache.flink.kubernetes.operator.exception.ValidationException
  • org.apache.flink.kubernetes.operator.docs.util.Utils
  • org.apache.flink.kubernetes.operator.utils.ValidatorUtils
  • org.apache.flink.autoscaler.topology.VertexInfo
  • org.apache.flink.autoscaler.event.VertexScalingReport

Interface Hierarchy

• org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher
• java.lang.AutoCloseable
  • java.io.Closeable
    • org.apache.flink.autoscaler.event.AutoScalerEventHandler<KEY,Context>
  • org.apache.flink.kubernetes.kubeclient.FlinkKubeClient
    • org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient
• org.apache.flink.autoscaler.state.AutoScalerStateStore<KEY,Context>
• org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics<CR>
• org.apache.flink.kubernetes.operator.api.diff.Diffable<T>
• org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceContext
  • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.FlinkResourceContext<R>
    • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.ResourceEventContext<R>
    • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.StatusUpdateContext<R,S>
  • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.FlinkStateSnapshotResourceContext
    • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.FlinkStateSnapshotEventContext
    • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener.FlinkStateSnapshotStatusUpdateContext
• org.apache.flink.kubernetes.operator.service.FlinkService
• org.apache.flink.autoscaler.JobAutoScaler<KEY,Context>
• org.apache.flink.autoscaler.standalone.JobListFetcher<KEY,Context>
• org.apache.flink.kubernetes.operator.observer.Observer<CR>
• org.apache.flink.core.plugin.Plugin
  • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
  • org.apache.flink.kubernetes.operator.mutator.FlinkResourceMutator
  • org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator
• org.apache.flink.kubernetes.operator.reconciler.Reconciler<CR>
• org.apache.flink.autoscaler.resources.ResourceCheck
• org.apache.flink.autoscaler.realizer.ScalingRealizer<KEY,Context>
• org.apache.flink.kubernetes.operator.api.status.Snapshot
• org.apache.flink.kubernetes.operator.api.status.SnapshotInfo

Annotation Type Hierarchy

• org.apache.flink.kubernetes.operator.api.diff.SpecDiff (implements java.lang.annotation.Annotation)
• org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Config (implements java.lang.annotation.Annotation)
• org.apache.flink.kubernetes.operator.api.diff.SpecDiff.Entry (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type
    • org.apache.flink.autoscaler.standalone.AutoscalerEventHandlerFactory.EventHandlerType (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.autoscaler.standalone.AutoscalerStateStoreFactory.StateStoreType (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.kubernetes.operator.api.status.CheckpointType (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.kubernetes.operator.api.diff.DiffType
    • org.apache.flink.kubernetes.operator.utils.EventRecorder.Component
    • org.apache.flink.kubernetes.operator.utils.EventRecorder.Reason
    • org.apache.flink.kubernetes.operator.utils.EventRecorder.Type
    • org.apache.flink.autoscaler.metrics.FlinkMetric
    • org.apache.flink.kubernetes.operator.api.status.FlinkStateSnapshotStatus.State
    • org.apache.flink.kubernetes.operator.api.spec.FlinkVersion
    • org.apache.flink.kubernetes.operator.health.HealthProbe
    • org.apache.flink.kubernetes.operator.api.spec.JobKind
    • org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
    • org.apache.flink.kubernetes.operator.api.spec.JobState
    • org.apache.flink.autoscaler.JobVertexScaler.ParallelismChangeType
    • org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
    • org.apache.flink.autoscaler.metrics.MetricAggregator
    • org.apache.flink.kubernetes.operator.config.Mode
    • org.apache.flink.kubernetes.operator.api.status.ReconciliationState
    • org.apache.flink.kubernetes.operator.api.lifecycle.ResourceLifecycleState
    • org.apache.flink.kubernetes.operator.api.status.SavepointFormatType
    • org.apache.flink.autoscaler.metrics.ScalingMetric
    • org.apache.flink.autoscaler.topology.ShipStrategy
    • org.apache.flink.kubernetes.operator.utils.SnapshotStatus
    • org.apache.flink.kubernetes.operator.api.status.SnapshotTriggerType
    • org.apache.flink.kubernetes.operator.reconciler.SnapshotType
    • org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
    • org.apache.flink.autoscaler.jdbc.state.StateType
    • org.apache.flink.kubernetes.operator.service.SuspendMode
    • org.apache.flink.kubernetes.operator.api.spec.UpgradeMode