Hierarchy For All Packages

Package Hierarchies:

• org.apache.flink.kubernetes.operator,
• org.apache.flink.kubernetes.operator.artifact,
• org.apache.flink.kubernetes.operator.config,
• org.apache.flink.kubernetes.operator.controller,
• org.apache.flink.kubernetes.operator.exception,
• org.apache.flink.kubernetes.operator.fs,
• org.apache.flink.kubernetes.operator.health,
• 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.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.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.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.utils.ConfigOptionUtils
  • 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>)
  • 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.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.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.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.artifact.HttpArtifactFetcher (implements org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher)
  • org.apache.flink.kubernetes.operator.health.HttpBootstrap
  • org.apache.flink.kubernetes.operator.utils.IngressUtils
  • 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.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.reconciler.ReconciliationUtils
  • org.apache.flink.kubernetes.operator.reconciler.diff.ReflectiveDiffBuilder<T> (implements org.apache.commons.lang3.builder.Builder<T>)
  • org.apache.flink.kubernetes.operator.metrics.lifecycle.ResourceLifecycleMetricTracker
  • org.apache.flink.kubernetes.operator.observer.SavepointFetchResult
  • 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.shaded.netty4.io.netty.handler.ssl.SslContext
    • org.apache.flink.kubernetes.operator.ssl.ReloadableSslContext
  • 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)
  • 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.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.utils.ValidatorUtils

Interface Hierarchy

• org.apache.flink.kubernetes.operator.artifact.ArtifactFetcher
• org.apache.flink.kubernetes.operator.metrics.CustomResourceMetrics<CR>
• 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.validation.FlinkResourceValidator
• org.apache.flink.kubernetes.operator.reconciler.Reconciler<CR>

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • 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.health.HealthProbe
    • org.apache.flink.kubernetes.operator.config.Mode
    • org.apache.flink.kubernetes.operator.utils.SavepointStatus