所有程序包的分层结构

程序包分层结构:

• org.apache.flink.cdc.common.annotation,
• org.apache.flink.cdc.common.configuration,
• org.apache.flink.cdc.common.configuration.description,
• org.apache.flink.cdc.common.data,
• org.apache.flink.cdc.common.data.binary,
• org.apache.flink.cdc.common.event,
• org.apache.flink.cdc.common.event.visitor,
• org.apache.flink.cdc.common.exceptions,
• org.apache.flink.cdc.common.factories,
• org.apache.flink.cdc.common.function,
• org.apache.flink.cdc.common.pipeline,
• org.apache.flink.cdc.common.route,
• org.apache.flink.cdc.common.schema,
• org.apache.flink.cdc.common.sink,
• org.apache.flink.cdc.common.source,
• org.apache.flink.cdc.common.text,
• org.apache.flink.cdc.common.types,
• org.apache.flink.cdc.common.types.utils,
• org.apache.flink.cdc.common.types.utils.runtime,
• org.apache.flink.cdc.common.udf,
• org.apache.flink.cdc.common.utils

类分层结构

• java.lang.Object
  • org.apache.flink.cdc.common.event.AddColumnEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent)
  • org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition (implements java.io.Serializable)
  • org.apache.flink.cdc.common.event.AlterColumnTypeEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent, org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema)
  • org.apache.flink.cdc.common.data.binary.BinarySection (implements org.apache.flink.cdc.common.data.binary.BinaryFormat)
    • org.apache.flink.cdc.common.data.binary.BinaryArrayData (implements org.apache.flink.cdc.common.data.ArrayData)
    • org.apache.flink.cdc.common.data.binary.BinaryMapData (implements org.apache.flink.cdc.common.data.MapData)
    • org.apache.flink.cdc.common.data.binary.BinaryRecordData (implements org.apache.flink.cdc.common.data.binary.NullAwareGetters, org.apache.flink.cdc.common.data.RecordData)
  • org.apache.flink.cdc.common.data.binary.BinarySegmentUtils
  • org.apache.flink.cdc.common.utils.ChangeEventUtils
  • org.apache.flink.cdc.common.schema.Column (implements java.io.Serializable)
    • org.apache.flink.cdc.common.schema.MetadataColumn
    • org.apache.flink.cdc.common.schema.PhysicalColumn
  • org.apache.flink.cdc.common.configuration.ConfigOption<T>
  • org.apache.flink.cdc.common.configuration.ConfigOptions
  • org.apache.flink.cdc.common.configuration.ConfigOptions.ListConfigOptionBuilder<E>
  • org.apache.flink.cdc.common.configuration.ConfigOptions.OptionBuilder
  • org.apache.flink.cdc.common.configuration.ConfigOptions.TypedConfigOptionBuilder<T>
  • org.apache.flink.cdc.common.configuration.Configuration (implements java.lang.Cloneable, java.io.Serializable)
  • org.apache.flink.cdc.common.configuration.ConfigurationUtils
  • org.apache.flink.cdc.common.event.CreateTableEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent)
  • org.apache.flink.cdc.common.event.DataChangeEvent (implements org.apache.flink.cdc.common.event.ChangeEvent, java.io.Serializable)
  • org.apache.flink.cdc.common.types.DataField (implements java.io.Serializable)
  • org.apache.flink.cdc.common.types.DataType (implements java.io.Serializable)
    • org.apache.flink.cdc.common.types.ArrayType
    • org.apache.flink.cdc.common.types.BigIntType
    • org.apache.flink.cdc.common.types.BinaryType
    • org.apache.flink.cdc.common.types.BooleanType
    • org.apache.flink.cdc.common.types.CharType
    • org.apache.flink.cdc.common.types.DateType
    • org.apache.flink.cdc.common.types.DecimalType
    • org.apache.flink.cdc.common.types.DoubleType
    • org.apache.flink.cdc.common.types.FloatType
    • org.apache.flink.cdc.common.types.IntType
    • org.apache.flink.cdc.common.types.LocalZonedTimestampType
    • org.apache.flink.cdc.common.types.MapType
    • org.apache.flink.cdc.common.types.RowType
    • org.apache.flink.cdc.common.types.SmallIntType
    • org.apache.flink.cdc.common.types.TimestampType
    • org.apache.flink.cdc.common.types.TimeType
    • org.apache.flink.cdc.common.types.TinyIntType
    • org.apache.flink.cdc.common.types.VarBinaryType
    • org.apache.flink.cdc.common.types.VarCharType
    • org.apache.flink.cdc.common.types.ZonedTimestampType
  • org.apache.flink.cdc.common.types.DataTypeChecks
  • org.apache.flink.cdc.common.types.DataTypeDefaultVisitor<R> (implements org.apache.flink.cdc.common.types.DataTypeVisitor<R>)
  • org.apache.flink.cdc.common.types.DataTypes
  • org.apache.flink.cdc.common.types.utils.DataTypeUtils
  • org.apache.flink.cdc.common.utils.DateTimeUtils
  • org.apache.flink.cdc.common.data.DecimalData (implements java.lang.Comparable<T>)
  • org.apache.flink.cdc.common.sink.DefaultDataChangeEventHashFunctionProvider (implements org.apache.flink.cdc.common.function.HashFunctionProvider<T>)
  • org.apache.flink.cdc.common.configuration.description.Description
  • org.apache.flink.cdc.common.configuration.description.Description.DescriptionBuilder
  • org.apache.flink.cdc.common.event.DropColumnEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent)
  • org.apache.flink.cdc.common.event.DropTableEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent)
  • org.apache.flink.cdc.common.utils.EncodingUtils
  • org.apache.flink.cdc.common.factories.FactoryHelper
  • org.apache.flink.cdc.common.factories.FactoryHelper.DefaultContext (implements org.apache.flink.cdc.common.factories.Factory.Context)
  • org.apache.flink.cdc.common.configuration.FallbackKey
  • org.apache.flink.cdc.common.event.FlushEvent (implements org.apache.flink.cdc.common.event.Event)
  • org.apache.flink.cdc.common.configuration.description.Formatter
    • org.apache.flink.cdc.common.configuration.description.HtmlFormatter
  • org.apache.flink.cdc.common.data.GenericArrayData (implements org.apache.flink.cdc.common.data.ArrayData)
  • org.apache.flink.cdc.common.data.GenericMapData (implements org.apache.flink.cdc.common.data.MapData)
  • java.io.InputStream (implements java.io.Closeable)
    • org.apache.flink.cdc.common.types.utils.runtime.DataInputViewStream
    • java.io.ObjectInputStream (implements java.io.ObjectInput, java.io.ObjectStreamConstants)
      • org.apache.flink.cdc.common.utils.InstantiationUtil.ClassLoaderObjectInputStream
  • org.apache.flink.cdc.common.utils.InstantiationUtil
  • org.apache.flink.cdc.common.data.binary.LazyBinaryFormat<T> (implements org.apache.flink.cdc.common.data.binary.BinaryFormat)
    • org.apache.flink.cdc.common.data.binary.BinaryStringData (implements org.apache.flink.cdc.common.data.StringData)
  • org.apache.flink.cdc.common.configuration.description.LineBreakElement (implements org.apache.flink.cdc.common.configuration.description.BlockElement, org.apache.flink.cdc.common.configuration.description.InlineElement)
  • org.apache.flink.cdc.common.configuration.description.LinkElement (implements org.apache.flink.cdc.common.configuration.description.InlineElement)
  • org.apache.flink.cdc.common.configuration.description.ListElement (implements org.apache.flink.cdc.common.configuration.description.BlockElement)
  • org.apache.flink.cdc.common.data.LocalZonedTimestampData (implements java.lang.Comparable<T>)
  • java.io.OutputStream (implements java.io.Closeable, java.io.Flushable)
    • org.apache.flink.cdc.common.types.utils.runtime.DataOutputViewStream
  • org.apache.flink.cdc.common.pipeline.PipelineOptions
  • org.apache.flink.cdc.common.text.Position
  • org.apache.flink.cdc.common.utils.Preconditions
  • org.apache.flink.cdc.common.utils.Predicates
  • org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByComma (implements org.apache.flink.cdc.common.text.TokenStream.Tokenizer)
  • org.apache.flink.cdc.common.utils.Predicates.RegExSplitterByDot (implements org.apache.flink.cdc.common.text.TokenStream.Tokenizer)
  • org.apache.flink.cdc.common.event.RenameColumnEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent)
  • org.apache.flink.cdc.common.route.RouteRule (implements java.io.Serializable)
  • org.apache.flink.cdc.common.types.RowType.Builder
  • org.apache.flink.cdc.common.schema.Schema (implements java.io.Serializable)
  • org.apache.flink.cdc.common.schema.Schema.Builder
  • org.apache.flink.cdc.common.event.SchemaChangeEventTypeFamily
  • org.apache.flink.cdc.common.event.visitor.SchemaChangeEventVisitor
  • org.apache.flink.cdc.common.utils.SchemaMergingUtils
  • org.apache.flink.cdc.common.utils.SchemaUtils
  • org.apache.flink.cdc.common.schema.Selectors
  • org.apache.flink.cdc.common.schema.Selectors.SelectorsBuilder
  • org.apache.flink.cdc.common.utils.StringUtf8Utils
  • org.apache.flink.cdc.common.utils.StringUtils
  • org.apache.flink.cdc.common.event.TableId (implements java.io.Serializable)
  • org.apache.flink.cdc.common.utils.TestCaseUtils
  • org.apache.flink.cdc.common.configuration.description.TextElement (implements org.apache.flink.cdc.common.configuration.description.BlockElement, org.apache.flink.cdc.common.configuration.description.InlineElement)
  • org.apache.flink.cdc.common.utils.ThreadLocalCache<K,V>
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • java.lang.RuntimeException
        • org.apache.flink.util.FlinkRuntimeException
          • org.apache.flink.cdc.common.exceptions.SchemaEvolveException
            • org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException
        • org.apache.flink.cdc.common.text.ParsingException
  • org.apache.flink.cdc.common.data.TimestampData (implements java.lang.Comparable<T>)
  • org.apache.flink.cdc.common.utils.TimeUtils
  • org.apache.flink.cdc.common.text.TokenStream
  • org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveToken (implements org.apache.flink.cdc.common.text.TokenStream.Token)
    • org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveToken
  • org.apache.flink.cdc.common.text.TokenStream.CharacterArrayStream (implements org.apache.flink.cdc.common.text.TokenStream.CharacterStream)
  • org.apache.flink.cdc.common.text.TokenStream.Marker (implements java.lang.Comparable<T>)
  • org.apache.flink.cdc.common.text.TokenStream.TokenFactory (implements org.apache.flink.cdc.common.text.TokenStream.Tokens)
    • org.apache.flink.cdc.common.text.TokenStream.CaseInsensitiveTokenFactory
    • org.apache.flink.cdc.common.text.TokenStream.CaseSensitiveTokenFactory
  • org.apache.flink.cdc.common.event.TruncateTableEvent (implements org.apache.flink.cdc.common.event.SchemaChangeEvent)
  • org.apache.flink.cdc.common.utils.TypeCheckUtils
  • org.apache.flink.cdc.common.data.ZonedTimestampData (implements java.lang.Comparable<T>)

接口分层结构

• org.apache.flink.cdc.common.event.visitor.AddColumnEventVisitor<T,E>
• org.apache.flink.cdc.common.event.visitor.AlterColumnTypeEventVisitor<T,E>
• org.apache.flink.cdc.common.data.ArrayData
• java.lang.AutoCloseable
  • org.apache.flink.cdc.common.sink.MetadataApplier (并 extends java.io.Serializable)
• org.apache.flink.cdc.common.data.binary.BinaryFormat
• java.lang.Comparable<T>
  • org.apache.flink.cdc.common.data.StringData
• org.apache.flink.cdc.common.event.visitor.CreateTableEventVisitor<T,E>
• org.apache.flink.cdc.common.sink.DataSink
• org.apache.flink.cdc.common.source.DataSource
• org.apache.flink.cdc.common.types.DataTypeVisitor<R>
• org.apache.flink.cdc.common.configuration.description.DescriptionElement
  • org.apache.flink.cdc.common.configuration.description.BlockElement
  • org.apache.flink.cdc.common.configuration.description.InlineElement
• org.apache.flink.cdc.common.event.visitor.DropColumnEventVisitor<T,E>
• org.apache.flink.cdc.common.event.visitor.DropTableEventVisitor<T,E>
• org.apache.flink.cdc.common.event.Event
  • org.apache.flink.cdc.common.event.ChangeEvent
    • org.apache.flink.cdc.common.event.SchemaChangeEvent (并 extends java.io.Serializable)
      • org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema
    • org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema
  • org.apache.flink.cdc.common.event.SchemaChangeEvent (并 extends org.apache.flink.cdc.common.event.ChangeEvent, java.io.Serializable)
    • org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema
  • org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema
• org.apache.flink.cdc.common.sink.EventSinkProvider
  • org.apache.flink.cdc.common.sink.FlinkSinkFunctionProvider
  • org.apache.flink.cdc.common.sink.FlinkSinkProvider
• org.apache.flink.cdc.common.source.EventSourceProvider
  • org.apache.flink.cdc.common.source.FlinkSourceFunctionProvider
  • org.apache.flink.cdc.common.source.FlinkSourceProvider
• org.apache.flink.cdc.common.factories.Factory
  • org.apache.flink.cdc.common.factories.DataSinkFactory
  • org.apache.flink.cdc.common.factories.DataSourceFactory
• org.apache.flink.cdc.common.factories.Factory.Context
• org.apache.flink.cdc.common.function.HashFunction<T>
• org.apache.flink.cdc.common.data.MapData
• org.apache.flink.cdc.common.source.MetadataAccessor
• org.apache.flink.cdc.common.data.binary.NullAwareGetters
• org.apache.flink.cdc.common.data.RecordData
• org.apache.flink.cdc.common.event.visitor.RenameColumnEventVisitor<T,E>
• java.io.Serializable
  • org.apache.flink.cdc.common.data.ArrayData.ElementGetter
  • org.apache.flink.cdc.common.event.EventDeserializer<T>
  • org.apache.flink.cdc.common.function.HashFunctionProvider<T>
  • org.apache.flink.cdc.common.sink.MetadataApplier (并 extends java.lang.AutoCloseable)
  • org.apache.flink.cdc.common.data.RecordData.FieldGetter
  • org.apache.flink.cdc.common.event.SchemaChangeEvent (并 extends org.apache.flink.cdc.common.event.ChangeEvent)
    • org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema
  • org.apache.flink.cdc.common.event.SchemaChangeEventWithPreSchema
  • org.apache.flink.cdc.common.source.SupportedMetadataColumn
• org.apache.flink.cdc.common.schema.TableFilter
• org.apache.flink.cdc.common.text.TokenStream.CharacterStream
• org.apache.flink.cdc.common.text.TokenStream.Token
• org.apache.flink.cdc.common.text.TokenStream.Tokenizer
• org.apache.flink.cdc.common.text.TokenStream.Tokens
• org.apache.flink.cdc.common.event.visitor.TruncateTableEventVisitor<T,E>
• org.apache.flink.cdc.common.udf.UserDefinedFunction
• org.apache.flink.cdc.common.udf.UserDefinedFunctionContext

注释类型分层结构

• org.apache.flink.cdc.common.annotation.Public (implements java.lang.annotation.Annotation)
• org.apache.flink.cdc.common.annotation.PublicEvolving (implements java.lang.annotation.Annotation)
• org.apache.flink.cdc.common.annotation.Internal (implements java.lang.annotation.Annotation)
• org.apache.flink.cdc.common.annotation.VisibleForTesting (implements java.lang.annotation.Annotation)
• org.apache.flink.cdc.common.annotation.Experimental (implements java.lang.annotation.Annotation)

枚举分层结构

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • org.apache.flink.cdc.common.pipeline.SchemaChangeBehavior
    • org.apache.flink.cdc.common.configuration.description.TextElement.TextStyle
    • org.apache.flink.cdc.common.types.DataTypeFamily
    • org.apache.flink.cdc.common.types.DataTypeRoot
    • org.apache.flink.cdc.common.event.OperationType
    • org.apache.flink.cdc.common.event.AddColumnEvent.ColumnPosition (implements java.io.Serializable)
    • org.apache.flink.cdc.common.event.SchemaChangeEventType