Hierarchy For All Packages

Package Hierarchies:

• 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.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.observer,
• org.apache.flink.kubernetes.operator.observer.deployment,
• org.apache.flink.kubernetes.operator.observer.sessionjob,
• 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.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.savepoints,
• org.apache.flink.runtime.rest.messages.job.savepoints.stop

Class Hierarchy

• java.lang.Object
  • org.apache.flink.kubernetes.operator.observer.AbstractFlinkResourceObserver<CR,CTX> (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.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
  • io.javaoperatorsdk.operator.api.config.AnnotationControllerConfiguration<P> (implements io.javaoperatorsdk.operator.api.config.ControllerConfiguration<R>)
    • io.javaoperatorsdk.operator.config.runtime.AnnotationControllerConfiguration<R>
      • org.apache.flink.kubernetes.operator.controller.FlinkControllerConfig<CR>
  • org.apache.flink.kubernetes.operator.artifact.ArtifactManager
  • org.apache.flink.kubernetes.operator.listener.AuditUtils
  • 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.service.CheckpointHistoryWrapper (implements org.apache.flink.runtime.rest.messages.ResponseBody)
  • 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.api.status.CommonStatus<SPEC>
    • org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus
    • org.apache.flink.kubernetes.operator.api.status.FlinkSessionJobStatus
  • 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.MessageHeaders<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.MessageHeaders<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)
  • 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.admissioncontroller.RequestHandler)
  • org.apache.flink.kubernetes.operator.validation.DefaultValidator (implements org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator)
  • 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.kubernetes.operator.utils.EnvUtils
  • 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.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.FlinkDeploymentObserverContext (implements org.apache.flink.kubernetes.operator.observer.ObserverContext)
  • org.apache.flink.kubernetes.operator.observer.deployment.FlinkDeploymentObserverFactory
  • org.apache.flink.kubernetes.operator.admission.mutator.FlinkMutator (implements io.javaoperatorsdk.admissioncontroller.mutation.Mutator<T>)
  • org.apache.flink.kubernetes.operator.FlinkOperator
  • org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration
  • org.apache.flink.kubernetes.operator.config.FlinkOperatorConfiguration.FlinkOperatorRetryConfiguration (implements io.javaoperatorsdk.operator.api.config.RetryConfiguration)
  • org.apache.flink.kubernetes.operator.admission.FlinkOperatorWebhook
  • org.apache.flink.kubernetes.operator.exception.FlinkResourceException
  • org.apache.flink.kubernetes.operator.utils.FlinkResourceExceptionUtils
  • org.apache.flink.kubernetes.operator.service.FlinkServiceFactory
  • 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.observer.sessionjob.FlinkSessionJobObserverContext (implements org.apache.flink.kubernetes.operator.observer.ObserverContext)
  • org.apache.flink.kubernetes.operator.utils.FlinkUtils
  • org.apache.flink.kubernetes.operator.admission.FlinkValidator (implements io.javaoperatorsdk.admissioncontroller.validation.Validator<T>)
  • 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.admission.informer.InformerManager
  • org.apache.flink.kubernetes.operator.api.spec.IngressSpec
  • org.apache.flink.kubernetes.operator.utils.IngressUtils
  • org.apache.flink.kubernetes.operator.api.spec.JobManagerSpec
  • org.apache.flink.kubernetes.operator.api.spec.JobSpec (implements org.apache.flink.kubernetes.operator.api.diff.Diffable<T>)
  • org.apache.flink.kubernetes.operator.api.status.JobStatus
  • org.apache.flink.kubernetes.operator.observer.JobStatusObserver<R,CTX>
  • org.apache.flink.kubernetes.operator.metrics.KubernetesClientMetrics (implements okhttp3.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.config.KubernetesOperatorConfigOptions
  • org.apache.flink.kubernetes.operator.metrics.KubernetesOperatorMetricOptions
  • 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
  • org.apache.flink.kubernetes.operator.metrics.MetricManager<CR>
  • 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.kubernetes.operator.api.spec.Resource
  • org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
  • org.apache.flink.kubernetes.operator.api.status.Savepoint
  • org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
  • org.apache.flink.kubernetes.operator.api.status.SavepointInfo
  • org.apache.flink.kubernetes.operator.observer.SavepointObserver<CR,STATUS>
  • org.apache.flink.runtime.rest.messages.job.savepoints.SavepointTriggerRequestBody (implements org.apache.flink.runtime.rest.messages.RequestBody)
  • org.apache.flink.kubernetes.operator.utils.SavepointUtils
  • 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.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.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.utils.StatusRecorder<CR,STATUS>
  • org.apache.flink.runtime.rest.messages.job.savepoints.stop.StopWithSavepointRequestBody (implements org.apache.flink.runtime.rest.messages.RequestBody)
  • 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.kubernetes.operator.exception.MissingJobManagerException
        • org.apache.flink.kubernetes.operator.exception.MissingSessionJobException
        • org.apache.flink.kubernetes.operator.exception.ReconciliationException
        • org.apache.flink.kubernetes.operator.exception.RecoveryFailureException
        • org.apache.flink.kubernetes.operator.exception.StatusConflictException
        • org.apache.flink.kubernetes.operator.exception.UnknownJobException
        • org.apache.flink.kubernetes.operator.exception.ValidationException
  • org.apache.flink.kubernetes.operator.docs.util.Utils
  • org.apache.flink.kubernetes.operator.utils.ValidatorUtils

Interface Hierarchy

• org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher
• java.lang.AutoCloseable
  • org.apache.flink.kubernetes.kubeclient.FlinkKubeClient
    • org.apache.flink.kubernetes.operator.kubeclient.FlinkStandaloneKubeClient
• 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<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.service.FlinkService
• org.apache.flink.kubernetes.operator.observer.Observer<CR>
• org.apache.flink.kubernetes.operator.observer.ObserverContext
• org.apache.flink.core.plugin.Plugin
  • org.apache.flink.kubernetes.operator.api.listener.FlinkResourceListener
  • org.apache.flink.kubernetes.operator.validation.FlinkResourceValidator
• org.apache.flink.kubernetes.operator.reconciler.Reconciler<CR>

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.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.kubernetes.operator.api.spec.FlinkVersion
    • org.apache.flink.kubernetes.operator.health.HealthProbe
    • org.apache.flink.kubernetes.operator.api.status.JobManagerDeploymentStatus
    • org.apache.flink.kubernetes.operator.api.spec.JobState
    • org.apache.flink.kubernetes.operator.api.spec.KubernetesDeploymentMode
    • 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.kubernetes.operator.utils.SavepointStatus
    • org.apache.flink.kubernetes.operator.api.status.SavepointTriggerType
    • org.apache.flink.kubernetes.operator.standalone.StandaloneKubernetesConfigOptionsInternal.ClusterMode
    • org.apache.flink.kubernetes.operator.api.spec.UpgradeMode