序列化表格 (flink-cdc-common 3.3.0 API)

程序包 org.apache.flink.cdc.common.configuration
- 类org.apache.flink.cdc.common.configuration.Configuration扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - confData
```
HashMap<K,V> confData
```
      Stores the concrete key/value pairs of this configuration object.
程序包 org.apache.flink.cdc.common.data
程序包 org.apache.flink.cdc.common.event
- 类org.apache.flink.cdc.common.event.AddColumnEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
    - addedColumns
```
List<E> addedColumns
```
- 类org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition扩展Object实现可序列化
  - 序列化字段
    - addColumn
```
Column addColumn
```
      The added column.
    - position
```
AddColumnEvent.ColumnPosition position
```
      The position of the added column.
    - existedColumnName
```
String existedColumnName
```
      The added column lies in the position relative to this column.
- 类org.apache.flink.cdc.common.event.AlterColumnTypeEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
    - typeMapping
```
Map<K,V> typeMapping
```
      key => column name, value => column type after changing.
    - oldTypeMapping
```
Map<K,V> oldTypeMapping
```
- 类org.apache.flink.cdc.common.event.CreateTableEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
    - schema
```
Schema schema
```
- 类org.apache.flink.cdc.common.event.DataChangeEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
    - before
```
RecordData before
```
      Describes the record of data before change.
    - after
```
RecordData after
```
      Describes the record of data after change.
    - op
```
OperationType op
```
      Describes the operation type of the change event. e.g. INSERT, UPDATE, REPLACE, DELETE.
    - meta
```
Map<K,V> meta
```
      Optional, describes the metadata of the change event. e.g. MySQL binlog file name, pos.
- 类org.apache.flink.cdc.common.event.DropColumnEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
    - droppedColumnNames
```
List<E> droppedColumnNames
```
- 类org.apache.flink.cdc.common.event.DropTableEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
- 类org.apache.flink.cdc.common.event.RenameColumnEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
    - nameMapping
```
Map<K,V> nameMapping
```
      key => column name before changing, value => column name after changing.
- 类org.apache.flink.cdc.common.event.TableId扩展Object实现可序列化
  - 序列化字段
    - namespace
```
String namespace
```
    - schemaName
```
String schemaName
```
    - tableName
```
String tableName
```
- 类org.apache.flink.cdc.common.event.TruncateTableEvent扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - tableId
```
TableId tableId
```
程序包 org.apache.flink.cdc.common.exceptions
- 类org.apache.flink.cdc.common.exceptions.SchemaEvolveException扩展org.apache.flink.util.FlinkRuntimeException实现可序列化
  - 序列化字段
    - applyingEvent
```
SchemaChangeEvent applyingEvent
```
    - exceptionMessage
```
String exceptionMessage
```
    - cause
```
Throwable cause
```
- 类org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException扩展SchemaEvolveException实现可序列化
程序包 org.apache.flink.cdc.common.function
程序包 org.apache.flink.cdc.common.route
- 类org.apache.flink.cdc.common.route.RouteRule扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - sourceTable
```
String sourceTable
```
    - sinkTable
```
String sinkTable
```
    - replaceSymbol
```
String replaceSymbol
```
程序包 org.apache.flink.cdc.common.schema
- 类org.apache.flink.cdc.common.schema.Column扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - name
```
String name
```
    - type
```
DataType type
```
    - comment
```
String comment
```
    - defaultValueExpression
```
String defaultValueExpression
```
      Save the literal value of the column's default value, For uncertain functions such as UUID(), the value is null, For the current time function such as CURRENT_TIMESTAMP(), the value is Unix Epoch time(1970-01-01 00:00:00).
- 类org.apache.flink.cdc.common.schema.MetadataColumn扩展Column实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - metadataKey
```
String metadataKey
```
- 类org.apache.flink.cdc.common.schema.PhysicalColumn扩展Column实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.schema.Schema扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - columns
```
List<E> columns
```
    - primaryKeys
```
List<E> primaryKeys
```
    - partitionKeys
```
List<E> partitionKeys
```
    - options
```
Map<K,V> options
```
    - comment
```
String comment
```
程序包 org.apache.flink.cdc.common.sink
- 类org.apache.flink.cdc.common.sink.DefaultDataChangeEventHashFunctionProvider扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
程序包 org.apache.flink.cdc.common.source
程序包 org.apache.flink.cdc.common.text
- 类org.apache.flink.cdc.common.text.ParsingException扩展RuntimeException实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - position
```
Position position
```
程序包 org.apache.flink.cdc.common.types
- 类org.apache.flink.cdc.common.types.ArrayType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - elementType
```
DataType elementType
```
- 类org.apache.flink.cdc.common.types.BigIntType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.BinaryType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - length
```
int length
```
- 类org.apache.flink.cdc.common.types.BooleanType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.CharType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - length
```
int length
```
- 类org.apache.flink.cdc.common.types.DataField扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - name
```
String name
```
    - type
```
DataType type
```
    - description
```
String description
```
- 类org.apache.flink.cdc.common.types.DataType扩展Object实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - isNullable
```
boolean isNullable
```
    - typeRoot
```
DataTypeRoot typeRoot
```
- 类org.apache.flink.cdc.common.types.DateType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.DecimalType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - precision
```
int precision
```
    - scale
```
int scale
```
- 类org.apache.flink.cdc.common.types.DoubleType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.FloatType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.IntType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.LocalZonedTimestampType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - precision
```
int precision
```
- 类org.apache.flink.cdc.common.types.MapType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - keyType
```
DataType keyType
```
    - valueType
```
DataType valueType
```
- 类org.apache.flink.cdc.common.types.RowType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - fields
```
List<E> fields
```
- 类org.apache.flink.cdc.common.types.SmallIntType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.TimestampType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - precision
```
int precision
```
- 类org.apache.flink.cdc.common.types.TimeType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - precision
```
int precision
```
- 类org.apache.flink.cdc.common.types.TinyIntType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
- 类org.apache.flink.cdc.common.types.VarBinaryType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - length
```
int length
```
- 类org.apache.flink.cdc.common.types.VarCharType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - length
```
int length
```
- 类org.apache.flink.cdc.common.types.ZonedTimestampType扩展DataType实现可序列化
  
  serialVersionUID:
  
  1L
  - 序列化字段
    - precision
```
int precision
```

序列化表格

程序包 org.apache.flink.cdc.common.configuration

类org.apache.flink.cdc.common.configuration.Configuration扩展Object实现可序列化

序列化字段

confData

程序包 org.apache.flink.cdc.common.data

程序包 org.apache.flink.cdc.common.event

类org.apache.flink.cdc.common.event.AddColumnEvent扩展Object实现可序列化

序列化字段

tableId

addedColumns

类org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition扩展Object实现可序列化

序列化字段

addColumn

position

existedColumnName

类org.apache.flink.cdc.common.event.AlterColumnTypeEvent扩展Object实现可序列化

序列化字段

tableId

typeMapping

oldTypeMapping

类org.apache.flink.cdc.common.event.CreateTableEvent扩展Object实现可序列化

序列化字段

tableId

schema

类org.apache.flink.cdc.common.event.DataChangeEvent扩展Object实现可序列化

序列化字段

tableId

before

after

op

meta

类org.apache.flink.cdc.common.event.DropColumnEvent扩展Object实现可序列化

序列化字段

tableId

droppedColumnNames

类org.apache.flink.cdc.common.event.DropTableEvent扩展Object实现可序列化

序列化字段

tableId

类org.apache.flink.cdc.common.event.RenameColumnEvent扩展Object实现可序列化

序列化字段

tableId

nameMapping

类org.apache.flink.cdc.common.event.TableId扩展Object实现可序列化

序列化字段

namespace

schemaName

tableName

类org.apache.flink.cdc.common.event.TruncateTableEvent扩展Object实现可序列化

序列化字段

tableId

程序包 org.apache.flink.cdc.common.exceptions

类org.apache.flink.cdc.common.exceptions.SchemaEvolveException扩展org.apache.flink.util.FlinkRuntimeException实现可序列化

序列化字段

applyingEvent

exceptionMessage

cause

类org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException扩展SchemaEvolveException实现可序列化

程序包 org.apache.flink.cdc.common.function

程序包 org.apache.flink.cdc.common.route

类org.apache.flink.cdc.common.route.RouteRule扩展Object实现可序列化

序列化字段

sourceTable

sinkTable

replaceSymbol

程序包 org.apache.flink.cdc.common.schema

类org.apache.flink.cdc.common.schema.Column扩展Object实现可序列化

序列化字段

name

type

comment

defaultValueExpression

类org.apache.flink.cdc.common.schema.MetadataColumn扩展Column实现可序列化

序列化字段

metadataKey

类org.apache.flink.cdc.common.schema.PhysicalColumn扩展Column实现可序列化

类org.apache.flink.cdc.common.schema.Schema扩展Object实现可序列化

序列化字段

columns

primaryKeys