Hierarchy For Package org.apache.paimon.flink

Package Hierarchies:

• All Packages

Class Hierarchy

• java.lang.Object
  • org.apache.flink.table.catalog.AbstractCatalog (implements org.apache.flink.table.catalog.Catalog)
    • org.apache.paimon.flink.FlinkCatalog
    • org.apache.paimon.flink.FlinkGenericCatalog
  • org.apache.flink.table.catalog.AbstractCatalogTable (implements org.apache.flink.table.catalog.CatalogTable)
    • org.apache.flink.table.catalog.CatalogTableImpl
      • org.apache.paimon.flink.DataCatalogTable
  • org.apache.paimon.flink.AbstractFlinkTableFactory (implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory)
    • org.apache.paimon.flink.FlinkTableFactory
  • org.apache.paimon.flink.DataTypeToLogicalType (implements org.apache.paimon.types.DataTypeVisitor<R>)
  • org.apache.paimon.flink.FlinkCatalogFactory (implements org.apache.flink.table.factories.CatalogFactory)
  • org.apache.paimon.flink.FlinkCatalogOptions
  • org.apache.paimon.flink.FlinkConnectorOptions
  • org.apache.paimon.flink.FlinkFileIO (implements org.apache.paimon.fs.FileIO)
  • org.apache.paimon.flink.FlinkFileIOLoader (implements org.apache.paimon.fs.FileIOLoader)
  • org.apache.paimon.flink.FlinkGenericCatalogFactory (implements org.apache.flink.table.factories.CatalogFactory)
  • org.apache.paimon.flink.FlinkGenericTableFactory (implements org.apache.flink.table.factories.DynamicTableSinkFactory, org.apache.flink.table.factories.DynamicTableSourceFactory)
  • org.apache.paimon.flink.FlinkRowData (implements org.apache.flink.table.data.RowData)
  • org.apache.paimon.flink.FlinkRowWrapper (implements org.apache.paimon.data.InternalRow)
  • org.apache.paimon.flink.FormatCatalogTable (implements org.apache.flink.table.catalog.CatalogTable)
  • org.apache.paimon.flink.LogicalTypeConversion
  • org.apache.flink.table.types.logical.utils.LogicalTypeDefaultVisitor<R> (implements org.apache.flink.table.types.logical.LogicalTypeVisitor<R>)
    • org.apache.paimon.flink.LogicalTypeToDataType
  • org.apache.paimon.flink.PaimonDataStreamScanProvider (implements org.apache.flink.table.connector.source.DataStreamScanProvider)
  • org.apache.paimon.flink.PaimonDataStreamSinkProvider (implements org.apache.flink.table.connector.sink.DataStreamSinkProvider)
  • org.apache.paimon.flink.PredicateConverter (implements org.apache.flink.table.expressions.ExpressionVisitor<R>)
  • org.apache.paimon.flink.ProjectedRowData (implements org.apache.flink.table.data.RowData)
  • org.apache.paimon.flink.Projection
  • org.apache.paimon.flink.SystemCatalogTable (implements org.apache.flink.table.catalog.CatalogTable)
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.paimon.flink.PredicateConverter.UnsupportedExpression
  • org.apache.paimon.flink.VersionedSerializerWrapper<T> (implements org.apache.flink.core.io.SimpleVersionedSerializer<E>)

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.paimon.flink.FlinkConnectorOptions.LookupCacheMode
    • org.apache.paimon.flink.FlinkConnectorOptions.WatermarkEmitStrategy (implements org.apache.paimon.options.description.DescribedEnum)
    • org.apache.paimon.flink.FlinkConnectorOptions.SplitAssignMode (implements org.apache.paimon.options.description.DescribedEnum)