Hierarchy For All Packages

Package Hierarchies:

• io.confluent.flink.plugin,
• org.apache.flink.annotation,
• org.apache.flink.api.common.typeinfo,
• org.apache.flink.configuration,
• org.apache.flink.configuration.description,
• org.apache.flink.core.execution,
• org.apache.flink.table.annotation,
• org.apache.flink.table.api,
• org.apache.flink.table.api.config,
• org.apache.flink.table.api.dataview,
• org.apache.flink.table.api.internal,
• org.apache.flink.table.catalog,
• org.apache.flink.table.connector,
• org.apache.flink.table.connector.format,
• org.apache.flink.table.connector.sink,
• org.apache.flink.table.connector.source,
• org.apache.flink.table.connector.source.abilities,
• org.apache.flink.table.data,
• org.apache.flink.table.expressions,
• org.apache.flink.table.factories,
• org.apache.flink.table.functions,
• org.apache.flink.table.module,
• org.apache.flink.table.operations,
• org.apache.flink.table.resource,
• org.apache.flink.table.runtime.functions,
• org.apache.flink.table.secret,
• org.apache.flink.table.types,
• org.apache.flink.table.types.inference,
• org.apache.flink.table.types.logical,
• org.apache.flink.types,
• org.apache.flink.util

Class Hierarchy

• java.lang.Object
  • org.apache.flink.table.api.internal.BaseExpressions<InType,OutType>
    • org.apache.flink.table.api.ApiExpression (implements org.apache.flink.table.expressions.Expression)
  • org.apache.flink.table.functions.BuiltInFunctionDefinitions
  • org.apache.flink.table.catalog.CatalogDescriptor
  • org.apache.flink.table.catalog.CatalogTable.Builder
  • org.apache.flink.table.connector.ChangelogMode
  • org.apache.flink.table.connector.ChangelogMode.Builder
  • org.apache.flink.util.CloseableIterator.IteratorAdapter<E> (implements org.apache.flink.util.CloseableIterator<T>)
  • org.apache.flink.types.ColumnList (implements java.io.Serializable)
  • org.apache.flink.configuration.ConfigOption<T>
  • org.apache.flink.configuration.ConfigOptions
  • org.apache.flink.configuration.ConfigOptions.ListConfigOptionBuilder<E>
  • org.apache.flink.configuration.ConfigOptions.OptionBuilder
  • org.apache.flink.configuration.ConfigOptions.TypedConfigOptionBuilder<T>
  • io.confluent.flink.plugin.ConfluentMLExpressions
  • io.confluent.flink.plugin.ConfluentPluginOptions
  • io.confluent.flink.plugin.ConfluentSettings
  • io.confluent.flink.plugin.ConfluentSettings.Builder
  • io.confluent.flink.plugin.ConfluentTools
  • org.apache.flink.table.types.DataType (implements org.apache.flink.table.types.AbstractDataType<T>, java.io.Serializable)
    • org.apache.flink.table.types.FieldsDataType
  • org.apache.flink.table.api.DataTypes
  • org.apache.flink.table.api.DataTypes.AbstractField
    • org.apache.flink.table.api.DataTypes.Field
    • org.apache.flink.table.api.DataTypes.UnresolvedField
  • org.apache.flink.table.api.DataTypes.Resolution
  • org.apache.flink.configuration.description.Description
  • org.apache.flink.configuration.description.Description.DescriptionBuilder
  • org.apache.flink.table.api.EnvironmentSettings
  • org.apache.flink.table.api.EnvironmentSettings.Builder
  • org.apache.flink.api.common.ExecutionConfig.GlobalJobParameters (implements java.io.Serializable)
    • org.apache.flink.configuration.Configuration (implements java.lang.Cloneable, org.apache.flink.core.io.IOReadableWritable, org.apache.flink.configuration.ReadableConfig, java.io.Serializable, org.apache.flink.configuration.WritableConfig)
  • org.apache.flink.table.api.config.ExecutionConfigOptions
  • org.apache.flink.table.api.Expressions
  • org.apache.flink.table.factories.FactoryUtil
  • org.apache.flink.table.factories.FactoryUtil.DefaultCatalogContext (implements org.apache.flink.table.factories.CatalogFactory.Context)
  • org.apache.flink.table.factories.FactoryUtil.DefaultCatalogStoreContext (implements org.apache.flink.table.factories.CatalogStoreFactory.Context)
  • org.apache.flink.table.factories.FactoryUtil.DefaultDynamicTableContext (implements org.apache.flink.table.factories.DynamicTableFactory.Context)
  • org.apache.flink.table.factories.FactoryUtil.DefaultModelProviderContext (implements org.apache.flink.table.factories.ModelProviderFactory.Context)
  • org.apache.flink.table.factories.FactoryUtil.DefaultModuleContext (implements org.apache.flink.table.factories.ModuleFactory.Context)
  • org.apache.flink.table.factories.FactoryUtil.DefaultSecretStoreContext (implements org.apache.flink.table.secret.SecretStoreFactory.Context)
  • org.apache.flink.table.factories.FactoryUtil.FactoryHelper<F>
    • org.apache.flink.table.factories.FactoryUtil.CatalogFactoryHelper
    • org.apache.flink.table.factories.FactoryUtil.CatalogStoreFactoryHelper
    • org.apache.flink.table.factories.FactoryUtil.ModelProviderFactoryHelper
    • org.apache.flink.table.factories.FactoryUtil.ModuleFactoryHelper
    • org.apache.flink.table.factories.FactoryUtil.TableFactoryHelper
  • org.apache.flink.table.api.FormatDescriptor
  • org.apache.flink.table.api.FormatDescriptor.Builder
  • org.apache.flink.configuration.description.Formatter
  • org.apache.flink.table.functions.FunctionContext
  • org.apache.flink.table.api.FunctionDescriptor
  • org.apache.flink.table.api.FunctionDescriptor.Builder
  • org.apache.flink.table.api.GroupWindow
    • org.apache.flink.table.api.SessionWithGapOnTimeWithAlias
    • org.apache.flink.table.api.SlideWithSizeAndSlideOnTimeWithAlias
    • org.apache.flink.table.api.TumbleWithSizeOnTimeWithAlias
  • org.apache.flink.table.api.InsertConflictStrategy (implements java.io.Serializable)
  • org.apache.flink.table.api.InsertConflictStrategy.Builder
  • org.apache.flink.table.api.dataview.ListView<T> (implements org.apache.flink.table.api.dataview.DataView)
  • org.apache.flink.table.types.logical.LogicalType (implements java.io.Serializable)
    • org.apache.flink.table.types.logical.ArrayType
    • org.apache.flink.table.types.logical.MapType
    • org.apache.flink.table.types.logical.RowType
    • org.apache.flink.table.types.logical.UserDefinedType
      • org.apache.flink.table.types.logical.StructuredType
  • org.apache.flink.table.api.dataview.MapView<K,V> (implements org.apache.flink.table.api.dataview.DataView)
  • org.apache.flink.configuration.MemorySize (implements java.lang.Comparable<T>, java.io.Serializable)
  • org.apache.flink.table.api.config.MLPredictRuntimeConfigOptions
  • org.apache.flink.table.api.ModelDescriptor
  • org.apache.flink.table.api.ModelDescriptor.Builder
  • org.apache.flink.table.module.ModuleEntry
  • io.confluent.flink.plugin.OAuthToken
  • org.apache.flink.table.catalog.ObjectIdentifier (implements java.io.Serializable)
  • org.apache.flink.table.api.config.OptimizerConfigOptions
  • org.apache.flink.table.api.Over
  • org.apache.flink.table.api.OverWindow
  • org.apache.flink.table.api.OverWindowPartitioned
  • org.apache.flink.table.api.OverWindowPartitionedOrdered
  • org.apache.flink.table.api.OverWindowPartitionedOrderedPreceding
  • org.apache.flink.configuration.PipelineOptions
  • org.apache.flink.table.runtime.functions.ProcessTableFunctionTestHarness<OUT> (implements java.lang.AutoCloseable)
  • org.apache.flink.table.runtime.functions.ProcessTableFunctionTestHarness.Builder<OUT>
  • org.apache.flink.table.catalog.ResolvedSchema
  • org.apache.flink.table.resource.ResourceUri
  • org.apache.flink.types.Row (implements java.io.Serializable)
  • org.apache.flink.table.types.logical.RowType.RowField (implements java.io.Serializable)
  • org.apache.flink.table.api.Schema
  • org.apache.flink.table.api.Schema.Builder
  • org.apache.flink.table.api.Schema.UnresolvedColumn
    • org.apache.flink.table.api.Schema.UnresolvedComputedColumn
    • org.apache.flink.table.api.Schema.UnresolvedMetadataColumn
    • org.apache.flink.table.api.Schema.UnresolvedPhysicalColumn
  • org.apache.flink.table.api.Schema.UnresolvedConstraint
    • org.apache.flink.table.api.Schema.UnresolvedImmutableColumns
    • org.apache.flink.table.api.Schema.UnresolvedPrimaryKey
  • org.apache.flink.table.api.Schema.UnresolvedIndex
  • org.apache.flink.table.api.Schema.UnresolvedWatermarkSpec
  • org.apache.flink.table.api.Session
  • org.apache.flink.table.api.SessionWithGap
  • org.apache.flink.table.api.SessionWithGapOnTime
  • org.apache.flink.table.api.Slide
  • org.apache.flink.table.api.SlideWithSize
  • org.apache.flink.table.api.SlideWithSizeAndSlide
  • org.apache.flink.table.api.SlideWithSizeAndSlideOnTime
  • org.apache.flink.table.expressions.SqlCallExpression (implements org.apache.flink.table.expressions.Expression)
  • io.confluent.flink.plugin.StatementHandle
  • io.confluent.flink.plugin.StatementWarning
  • org.apache.flink.table.types.inference.StaticArgument
  • org.apache.flink.table.types.logical.StructuredType.Builder
  • org.apache.flink.table.types.logical.StructuredType.StructuredAttribute (implements java.io.Serializable)
  • org.apache.flink.table.api.TableConfig (implements org.apache.flink.configuration.ReadableConfig, org.apache.flink.configuration.WritableConfig)
  • org.apache.flink.table.api.config.TableConfigOptions
  • org.apache.flink.table.api.TableDescriptor
    • io.confluent.flink.plugin.ConfluentTableDescriptor
  • org.apache.flink.table.api.TableDescriptor.Builder
    • io.confluent.flink.plugin.ConfluentTableDescriptor.Builder
  • org.apache.flink.table.catalog.TableDistribution
  • org.apache.flink.configuration.description.TextElement (implements org.apache.flink.configuration.description.BlockElement, org.apache.flink.configuration.description.InlineElement)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • io.confluent.flink.plugin.ActionCompletedException
        • io.confluent.flink.plugin.ConfluentFlinkException
  • org.apache.flink.table.runtime.functions.Timer (implements java.lang.Comparable<T>)
  • org.apache.flink.table.api.Tumble
  • org.apache.flink.table.api.TumbleWithSize
  • org.apache.flink.table.api.TumbleWithSizeOnTime
  • org.apache.flink.table.types.inference.TypeInference
  • org.apache.flink.table.types.inference.TypeInference.Builder
  • org.apache.flink.api.common.typeinfo.TypeInformation<T> (implements java.io.Serializable)
    • org.apache.flink.api.common.typeinfo.SqlTimeTypeInfo<T> (implements org.apache.flink.api.common.typeinfo.AtomicType<T>)
  • org.apache.flink.table.types.UnresolvedDataType (implements org.apache.flink.table.types.AbstractDataType<T>)
  • org.apache.flink.table.functions.UserDefinedFunction (implements org.apache.flink.table.functions.FunctionDefinition, java.io.Serializable)
    • org.apache.flink.table.functions.ProcessTableFunction<T>
    • org.apache.flink.table.functions.ScalarFunction
    • org.apache.flink.table.functions.TableFunction<T>
      • org.apache.flink.table.functions.TemporalTableFunction

Interface Hierarchy

• org.apache.flink.table.types.AbstractDataType<T>
• org.apache.flink.table.api.AggregatedTable
• java.lang.AutoCloseable
  • org.apache.flink.util.CloseableIterator<T> (also extends java.util.Iterator<E>)
• org.apache.flink.table.catalog.Catalog
• org.apache.flink.table.catalog.CatalogBaseTable
  • org.apache.flink.table.catalog.CatalogTable
• org.apache.flink.table.catalog.CatalogFunction
• org.apache.flink.table.catalog.CatalogModel
• org.apache.flink.table.catalog.CatalogStore
• org.apache.flink.util.Collector<T>
• org.apache.flink.table.api.Compilable
  • org.apache.flink.table.api.StatementSet (also extends org.apache.flink.table.api.Executable, org.apache.flink.table.api.Explainable<SELF>)
  • org.apache.flink.table.api.TablePipeline (also extends org.apache.flink.table.api.Executable, org.apache.flink.table.api.Explainable<SELF>)
• org.apache.flink.table.catalog.DataTypeFactory
• org.apache.flink.configuration.DescribedEnum
• org.apache.flink.configuration.description.DescriptionElement
  • org.apache.flink.configuration.description.InlineElement
• org.apache.flink.table.connector.sink.DynamicTableSink
• org.apache.flink.table.connector.sink.DynamicTableSink.Context
• org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider
• org.apache.flink.table.connector.source.DynamicTableSource
• org.apache.flink.table.connector.source.DynamicTableSource.Context
• org.apache.flink.table.api.Executable
  • org.apache.flink.table.api.StatementSet (also extends org.apache.flink.table.api.Compilable, org.apache.flink.table.api.Explainable<SELF>)
  • org.apache.flink.table.api.Table (also extends org.apache.flink.table.api.Explainable<SELF>)
  • org.apache.flink.table.api.TablePipeline (also extends org.apache.flink.table.api.Compilable, org.apache.flink.table.api.Explainable<SELF>)
• org.apache.flink.table.api.Explainable<SELF>
  • org.apache.flink.table.api.StatementSet (also extends org.apache.flink.table.api.Compilable, org.apache.flink.table.api.Executable)
  • org.apache.flink.table.api.Table (also extends org.apache.flink.table.api.Executable)
  • org.apache.flink.table.api.TablePipeline (also extends org.apache.flink.table.api.Compilable, org.apache.flink.table.api.Executable)
• org.apache.flink.table.expressions.Expression
  • org.apache.flink.table.expressions.ResolvedExpression
• org.apache.flink.table.expressions.ExpressionVisitor<R>
• org.apache.flink.table.api.FlatAggregateTable
• org.apache.flink.table.connector.format.Format
• org.apache.flink.table.functions.FunctionDefinition
• org.apache.flink.table.api.GroupedTable
• org.apache.flink.table.api.GroupWindowedTable
• java.util.Iterator<E>
  • org.apache.flink.util.CloseableIterator<T> (also extends java.lang.AutoCloseable)
• org.apache.flink.core.execution.JobClient
• org.apache.flink.table.api.Model
• org.apache.flink.table.module.Module
• io.confluent.flink.plugin.OAuthTokenProvider
• org.apache.flink.table.operations.Operation
  • org.apache.flink.table.operations.QueryOperation
• org.apache.flink.table.api.OverWindowedTable
• org.apache.flink.table.api.PartitionedTable
• org.apache.flink.table.api.PlannerConfig
• org.apache.flink.table.functions.ProcessTableFunction.Context
  • org.apache.flink.table.functions.ProcessTableFunction.OnTimerContext
• org.apache.flink.table.functions.ProcessTableFunction.TimeContext<TimeType>
• org.apache.flink.configuration.ReadableConfig
• org.apache.flink.table.data.RowData
• org.apache.flink.table.secret.SecretStore
• java.io.Serializable
  • org.apache.flink.table.data.RowData.FieldGetter
  • org.apache.flink.table.connector.RuntimeConverter
    • org.apache.flink.table.connector.sink.DynamicTableSink.DataStructureConverter
    • org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter
• org.apache.flink.table.expressions.SqlFactory
• org.apache.flink.table.connector.source.abilities.SupportsSourceWatermark
• org.apache.flink.table.api.TableEnvironment
• org.apache.flink.table.api.TableResult
• org.apache.flink.table.functions.TableSemantics
• org.apache.flink.table.types.inference.TypeStrategy
  • org.apache.flink.table.types.inference.StateTypeStrategy
• org.apache.flink.table.api.WindowGroupedTable
• org.apache.flink.configuration.WritableConfig

Annotation Type Hierarchy

• org.apache.flink.annotation.Experimental (implements java.lang.annotation.Annotation)
• org.apache.flink.annotation.Internal (implements java.lang.annotation.Annotation)
• org.apache.flink.annotation.PublicEvolving (implements java.lang.annotation.Annotation)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.lang.constant.Constable, java.io.Serializable)
    • org.apache.flink.table.api.config.AggregatePhaseStrategy
    • org.apache.flink.table.annotation.ArgumentTrait
    • io.confluent.flink.plugin.AuthMode
    • org.apache.flink.table.api.config.ExecutionConfigOptions.AsyncOutputMode
    • org.apache.flink.table.api.config.ExecutionConfigOptions.LegacyCastBehaviour (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.ExecutionConfigOptions.NestedEnforcer (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.ExecutionConfigOptions.NotNullEnforcer (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.ExecutionConfigOptions.RetryStrategy
    • org.apache.flink.table.api.config.ExecutionConfigOptions.RowtimeInserter (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.ExecutionConfigOptions.SinkKeyedShuffle
    • org.apache.flink.table.api.config.ExecutionConfigOptions.SinkUpsertMaterializeStrategy
    • org.apache.flink.table.api.config.ExecutionConfigOptions.TypeLengthEnforcer (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.ExecutionConfigOptions.UidGeneration (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.ExecutionConfigOptions.UpsertMaterialize
    • org.apache.flink.table.api.ExplainDetail
    • org.apache.flink.table.api.ExplainFormat
    • org.apache.flink.table.functions.FunctionKind
    • org.apache.flink.table.catalog.FunctionLanguage
    • org.apache.flink.table.api.InsertConflictStrategy.ConflictBehavior
    • org.apache.flink.table.api.JsonExistsOnError (implements org.apache.flink.table.expressions.TableSymbol)
    • org.apache.flink.table.api.JsonQueryOnEmptyOrError (implements org.apache.flink.table.expressions.TableSymbol)
    • org.apache.flink.table.api.JsonQueryWrapper (implements org.apache.flink.table.expressions.TableSymbol)
    • org.apache.flink.table.api.JsonType (implements org.apache.flink.table.expressions.TableSymbol)
    • org.apache.flink.table.api.JsonValueOnEmptyOrError (implements org.apache.flink.table.expressions.TableSymbol)
    • org.apache.flink.configuration.MemorySize.MemoryUnit
    • io.confluent.flink.plugin.OnConflictMode
    • org.apache.flink.table.api.config.OptimizerConfigOptions.AdaptiveBroadcastJoinStrategy (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.OptimizerConfigOptions.AdaptiveSkewedJoinOptimizationStrategy (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.OptimizerConfigOptions.DeltaJoinStrategy (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.OptimizerConfigOptions.NonDeterministicUpdateStrategy
    • org.apache.flink.configuration.PipelineOptions.VertexDescriptionMode
    • io.confluent.flink.plugin.PluginAction
    • org.apache.flink.table.api.ResultKind
    • org.apache.flink.types.RowKind
    • org.apache.flink.table.api.SqlDialect
    • io.confluent.flink.plugin.StatementWarning.Severity
    • org.apache.flink.table.types.inference.StaticArgumentTrait
    • org.apache.flink.table.types.logical.StructuredType.StructuredComparison
    • org.apache.flink.table.api.config.TableConfigOptions.CatalogPlanCompilation (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.TableConfigOptions.CatalogPlanRestore (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.api.config.TableConfigOptions.ColumnExpansionStrategy (implements org.apache.flink.configuration.DescribedEnum)
    • org.apache.flink.table.catalog.TableDistribution.Kind
    • org.apache.flink.table.functions.TableSemantics.SortDirection
    • org.apache.flink.configuration.description.TextElement.TextStyle
    • org.apache.flink.table.expressions.TimeIntervalUnit (implements org.apache.flink.table.expressions.TableSymbol)
    • org.apache.flink.table.expressions.TimePointUnit (implements org.apache.flink.table.expressions.TableSymbol)