Serialized Form (flink-cdc-parent 3.8-SNAPSHOT API)

Package com.github.shyiko.mysql.binlog.event.deserialization
- Class com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException extends IOException implements Serializable
  - Serialized Fields
    - eventHeader
      
      com.github.shyiko.mysql.binlog.event.EventHeader eventHeader
- Class com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.EventDataWrapper extends Object implements Serializable
  - Serialized Fields
    - external
      
      com.github.shyiko.mysql.binlog.event.EventData external
    - internal
      
      com.github.shyiko.mysql.binlog.event.EventData internal
- Class com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException extends IOException implements Serializable

Package com.oceanbase.connector.flink.sink

Class com.oceanbase.connector.flink.sink.OceanBaseRecordFlusher extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

connectionProvider

com.oceanbase.connector.flink.connection.OceanBaseConnectionProvider connectionProvider

dialect

com.oceanbase.connector.flink.dialect.OceanBaseDialect dialect

directLoadCache

com.oceanbase.connector.flink.utils.TableCache<com.alipay.oceanbase.rpc.table.ObTableDirectLoad> directLoadCache

lastCheckMemStoreTime
```
long lastCheckMemStoreTime
```

options

com.oceanbase.connector.flink.OceanBaseConnectorOptions options

tablePartInfoCache

com.oceanbase.connector.flink.utils.TableCache<com.oceanbase.connector.flink.connection.OceanBaseTablePartInfo> tablePartInfoCache

Class com.oceanbase.connector.flink.sink.OceanBaseSink extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

keyExtractor

com.oceanbase.connector.flink.table.DataChangeRecord.KeyExtractor keyExtractor

options

com.oceanbase.connector.flink.ConnectorOptions options

recordFlusher

com.oceanbase.connector.flink.sink.RecordFlusher recordFlusher

recordSerializer

com.oceanbase.connector.flink.table.RecordSerializationSchema<T> recordSerializer

typeSerializer

org.apache.flink.api.common.typeutils.TypeSerializer<T> typeSerializer

writerEventListener

com.oceanbase.connector.flink.sink.OceanBaseWriterEvent.Listener writerEventListener

Package io.debezium.connector.mysql
- Class io.debezium.connector.mysql.EventDataDeserializationExceptionData extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - cause
      
      com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException cause
- Class io.debezium.connector.mysql.StopEventData extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package io.debezium.embedded
- Class io.debezium.embedded.StopConnectorException extends io.debezium.DebeziumException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.calcite.sql.type
- Class org.apache.calcite.sql.type.AbstractSqlType extends org.apache.calcite.rel.type.RelDataTypeImpl implements Serializable
  - Serialized Fields
    - isNullable
      
      boolean isNullable
    - typeName
      
      SqlTypeName typeName
- Class org.apache.calcite.sql.type.ArraySqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable
  - Serialized Fields
    - elementType
      
      org.apache.calcite.rel.type.RelDataType elementType
- Class org.apache.calcite.sql.type.BasicSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable
  - Serialized Fields
    - collation
      
      org.apache.calcite.sql.SqlCollation collation
    - precision
      
      int precision
    - scale
      
      int scale
    - typeSystem
      
      org.apache.calcite.rel.type.RelDataTypeSystem typeSystem
    - wrappedCharset
      
      org.apache.calcite.util.SerializableCharset wrappedCharset
- Class org.apache.calcite.sql.type.IntervalSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable
  - Serialized Fields
    - intervalQualifier
      
      org.apache.calcite.sql.SqlIntervalQualifier intervalQualifier
    - typeSystem
      
      org.apache.calcite.rel.type.RelDataTypeSystem typeSystem
- Class org.apache.calcite.sql.type.MapSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable
  - Serialized Fields
    - keyType
      
      org.apache.calcite.rel.type.RelDataType keyType
    - valueType
      
      org.apache.calcite.rel.type.RelDataType valueType
- Class org.apache.calcite.sql.type.MultisetSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable
  - Serialized Fields
    - elementType
      
      org.apache.calcite.rel.type.RelDataType elementType
- Class org.apache.calcite.sql.type.ObjectSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable
  - Serialized Fields
    - comparability
      
      org.apache.calcite.rel.type.RelDataTypeComparability comparability
    - family
      
      org.apache.calcite.rel.type.RelDataTypeFamily family
    - sqlIdentifier
      
      org.apache.calcite.sql.SqlIdentifier sqlIdentifier

Package org.apache.doris.flink.sink.batch

Class org.apache.doris.flink.sink.batch.DorisBatchSink extends Object implements Serializable

Serialized Fields

dorisExecutionOptions

org.apache.doris.flink.cfg.DorisExecutionOptions dorisExecutionOptions

Deprecated.

dorisOptions

org.apache.doris.flink.cfg.DorisOptions dorisOptions

Deprecated.

dorisReadOptions

org.apache.doris.flink.cfg.DorisReadOptions dorisReadOptions

Deprecated.

serializer

org.apache.doris.flink.sink.writer.serializer.DorisRecordSerializer<IN> serializer

Deprecated.

Class org.apache.doris.flink.sink.batch.DorisBatchStreamLoad extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

backendUtil

org.apache.doris.flink.sink.BackendUtil backendUtil

block
```
Condition block
```

bufferMap

Map<String,org.apache.doris.flink.sink.batch.BatchRecordBuffer> bufferMap

bufferMapLock

Map<String,ReadWriteLock> bufferMapLock

currentCacheBytes
```
AtomicLong currentCacheBytes
```
enableGroupCommit
```
boolean enableGroupCommit
```
enableGzCompress
```
boolean enableGzCompress
```
exception
```
AtomicReference<Throwable> exception
```

executionOptions

org.apache.doris.flink.cfg.DorisExecutionOptions executionOptions

flushQueue

BlockingQueue<org.apache.doris.flink.sink.batch.BatchRecordBuffer> flushQueue

hostPort
```
String hostPort
```

httpClientBuilder

org.apache.http.impl.client.HttpClientBuilder httpClientBuilder

labelGenerator

org.apache.doris.flink.sink.writer.LabelGenerator labelGenerator

lineDelimiter
```
byte[] lineDelimiter
```

loadAsyncExecutor

org.apache.doris.flink.sink.batch.DorisBatchStreamLoad.LoadAsyncExecutor loadAsyncExecutor

loadExecutorService
```
ExecutorService loadExecutorService
```
loadProps
```
Properties loadProps
```
loadThreadAlive
```
boolean loadThreadAlive
```
loadUrl
```
String loadUrl
```
lock
```
Lock lock
```
maxBlockedBytes
```
long maxBlockedBytes
```
password
```
String password
```
started
```
AtomicBoolean started
```
subTaskId
```
int subTaskId
```
username
```
String username
```

Package org.apache.flink.cdc.common.configuration
- Class org.apache.flink.cdc.common.configuration.Configuration extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - confData
      
      HashMap<String,Object> confData
      
      Stores the concrete key/value pairs of this configuration object.
Package org.apache.flink.cdc.common.data
Package org.apache.flink.cdc.common.event
- Class org.apache.flink.cdc.common.event.AddColumnEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - addedColumns
      
      List<AddColumnEvent.ColumnWithPosition> addedColumns
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.AddColumnEvent.ColumnWithPosition extends Object implements Serializable
  - Serialized Fields
    - addColumn
      
      Column addColumn
      
      The added column.
    - existedColumnName
      
      String existedColumnName
      
      The added column lies in the position relative to this column.
    - position
      
      AddColumnEvent.ColumnPosition position
      
      The position of the added column.
- Class org.apache.flink.cdc.common.event.AlterColumnTypeEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comments
      
      Map<String,String> comments
      
      key => column name, value => column comment after changing.
    - oldTypeMapping
      
      Map<String,DataType> oldTypeMapping
    - tableId
      
      TableId tableId
    - typeMapping
      
      Map<String,DataType> typeMapping
      
      key => column name, value => column type after changing.
- Class org.apache.flink.cdc.common.event.AlterTableCommentEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - comment
      
      String comment
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.CreateTableEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schema
      
      Schema schema
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.DataChangeEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - after
      
      RecordData after
      
      Describes the record of data after change.
    - before
      
      RecordData before
      
      Describes the record of data before change.
    - meta
      
      Map<String,String> meta
      
      Optional, describes the metadata of the change event. e.g. MySQL binlog file name, pos.
    - op
      
      OperationType op
      
      Describes the operation type of the change event. e.g. INSERT, UPDATE, REPLACE, DELETE.
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.DropColumnEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - droppedColumnNames
      
      List<String> droppedColumnNames
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.DropTableEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.RenameColumnEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nameMapping
      
      Map<String,String> nameMapping
      
      key => column name before changing, value => column name after changing.
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.common.event.TableId extends Object implements Serializable
  - Serialized Fields
    - namespace
      
      String namespace
    - schemaName
      
      String schemaName
    - tableName
      
      String tableName
- Class org.apache.flink.cdc.common.event.TruncateTableEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableId
      
      TableId tableId
Package org.apache.flink.cdc.common.exceptions
- Class org.apache.flink.cdc.common.exceptions.SchemaEvolveException extends org.apache.flink.util.FlinkRuntimeException implements Serializable
  - Serialized Fields
    - applyingEvent
      
      SchemaChangeEvent applyingEvent
    - cause
      
      Throwable cause
    - exceptionMessage
      
      String exceptionMessage
- Class org.apache.flink.cdc.common.exceptions.UnsupportedSchemaChangeEventException extends SchemaEvolveException implements Serializable
Package org.apache.flink.cdc.common.function
Package org.apache.flink.cdc.common.model
Package org.apache.flink.cdc.common.route
- Class org.apache.flink.cdc.common.route.RouteRule extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - replaceSymbol
      
      String replaceSymbol
    - sinkTable
      
      String sinkTable
    - sourceTable
      
      String sourceTable
Package org.apache.flink.cdc.common.schema
- Class org.apache.flink.cdc.common.schema.Column extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - 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).
    - name
      
      String name
    - type
      
      DataType type
- Class org.apache.flink.cdc.common.schema.MetadataColumn extends Column implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - metadataKey
      
      String metadataKey
- Class org.apache.flink.cdc.common.schema.PhysicalColumn extends Column implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.schema.Schema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columns
      
      List<Column> columns
    - comment
      
      String comment
    - options
      
      Map<String,String> options
    - partitionKeys
      
      List<String> partitionKeys
    - primaryKeys
      
      List<String> primaryKeys
Package org.apache.flink.cdc.common.sink
- Class org.apache.flink.cdc.common.sink.DefaultDataChangeEventHashFunctionProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.sink.ForwardHashFunctionProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.sink.TableIdHashFunctionProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.common.source
Package org.apache.flink.cdc.common.source.discover
- Class org.apache.flink.cdc.common.source.discover.JdbcTableDiscoverer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.common.text
- Class org.apache.flink.cdc.common.text.ParsingException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - position
      
      Position position
Package org.apache.flink.cdc.common.types
- Class org.apache.flink.cdc.common.types.ArrayType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - elementType
      
      DataType elementType
- Class org.apache.flink.cdc.common.types.BigIntType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.BinaryType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - length
      
      int length
- Class org.apache.flink.cdc.common.types.BooleanType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.CharType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - length
      
      int length
- Class org.apache.flink.cdc.common.types.DataField extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - description
      
      String description
    - name
      
      String name
    - type
      
      DataType type
- Class org.apache.flink.cdc.common.types.DataType extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - isNullable
      
      boolean isNullable
    - typeRoot
      
      DataTypeRoot typeRoot
- Class org.apache.flink.cdc.common.types.DateType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.DecimalType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
    - scale
      
      int scale
- Class org.apache.flink.cdc.common.types.DoubleType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.FloatType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.IntType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.LocalZonedTimestampType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
- Class org.apache.flink.cdc.common.types.MapType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - keyType
      
      DataType keyType
    - valueType
      
      DataType valueType
- Class org.apache.flink.cdc.common.types.RowType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fields
      
      List<DataField> fields
- Class org.apache.flink.cdc.common.types.SmallIntType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.TimestampType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
- Class org.apache.flink.cdc.common.types.TimeType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
- Class org.apache.flink.cdc.common.types.TinyIntType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.common.types.VarBinaryType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - length
      
      int length
- Class org.apache.flink.cdc.common.types.VarCharType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - length
      
      int length
- Class org.apache.flink.cdc.common.types.VariantType extends DataType implements Serializable
- Class org.apache.flink.cdc.common.types.ZonedTimestampType extends DataType implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
Package org.apache.flink.cdc.common.types.variant
- Class org.apache.flink.cdc.common.types.variant.VariantTypeException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.base.config
- Class org.apache.flink.cdc.connectors.base.config.BaseSourceConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assignUnboundedChunkFirst
      
      boolean assignUnboundedChunkFirst
    - closeIdleReaders
      
      boolean closeIdleReaders
    - dbzProperties
      
      Properties dbzProperties
    - distributionFactorLower
      
      double distributionFactorLower
    - distributionFactorUpper
      
      double distributionFactorUpper
    - includeSchemaChanges
      
      boolean includeSchemaChanges
    - isScanNewlyAddedTableEnabled
      
      boolean isScanNewlyAddedTableEnabled
    - releaseSnapshotMetadataEnabled
      
      boolean releaseSnapshotMetadataEnabled
    - skipSnapshotBackfill
      
      boolean skipSnapshotBackfill
    - splitMetaGroupSize
      
      int splitMetaGroupSize
    - splitSize
      
      int splitSize
    - startupOptions
      
      StartupOptions startupOptions
- Class org.apache.flink.cdc.connectors.base.config.JdbcSourceConfig extends BaseSourceConfig implements Serializable
  - Serialized Fields
    - chunkKeyColumn
      
      String chunkKeyColumn
    - connectionPoolSize
      
      int connectionPoolSize
    - connectMaxRetries
      
      int connectMaxRetries
    - connectTimeout
      
      java.time.Duration connectTimeout
    - databaseList
      
      List<String> databaseList
    - driverClassName
      
      String driverClassName
    - fetchSize
      
      int fetchSize
    - hostname
      
      String hostname
    - password
      
      String password
    - port
      
      int port
    - schemaList
      
      List<String> schemaList
    - serverTimeZone
      
      String serverTimeZone
    - tableList
      
      List<String> tableList
    - username
      
      String username
- Class org.apache.flink.cdc.connectors.base.config.JdbcSourceConfigFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assignUnboundedChunkFirst
      
      boolean assignUnboundedChunkFirst
    - chunkKeyColumn
      
      String chunkKeyColumn
    - closeIdleReaders
      
      boolean closeIdleReaders
    - connectionPoolSize
      
      int connectionPoolSize
    - connectMaxRetries
      
      int connectMaxRetries
    - connectTimeout
      
      java.time.Duration connectTimeout
    - databaseList
      
      List<String> databaseList
    - dbzProperties
      
      Properties dbzProperties
    - distributionFactorLower
      
      double distributionFactorLower
    - distributionFactorUpper
      
      double distributionFactorUpper
    - fetchSize
      
      int fetchSize
    - hostname
      
      String hostname
    - includeSchemaChanges
      
      boolean includeSchemaChanges
    - password
      
      String password
    - port
      
      int port
    - releaseSnapshotMetadataEnabled
      
      boolean releaseSnapshotMetadataEnabled
    - scanNewlyAddedTableEnabled
      
      boolean scanNewlyAddedTableEnabled
    - serverTimeZone
      
      String serverTimeZone
    - skipSnapshotBackfill
      
      boolean skipSnapshotBackfill
    - splitMetaGroupSize
      
      int splitMetaGroupSize
    - splitSize
      
      int splitSize
    - startupOptions
      
      StartupOptions startupOptions
    - tableList
      
      List<String> tableList
    - username
      
      String username
Package org.apache.flink.cdc.connectors.base.dialect
Package org.apache.flink.cdc.connectors.base.options
- Class org.apache.flink.cdc.connectors.base.options.StartupOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
      
      Map<String,String> offset
    - specificOffsetFile
      
      String specificOffsetFile
    - specificOffsetPos
      
      Integer specificOffsetPos
    - startupMode
      
      StartupMode startupMode
    - startupTimestampMillis
      
      Long startupTimestampMillis
Package org.apache.flink.cdc.connectors.base.relational.connection
- Class org.apache.flink.cdc.connectors.base.relational.connection.ConnectionPoolId extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - database
      
      String database
    - dataSourcePoolFactoryIdentifier
      
      String dataSourcePoolFactoryIdentifier
      
      the identifier of a data source pool factory is its class name.
    - host
      
      String host
    - port
      
      int port
    - username
      
      String username
Package org.apache.flink.cdc.connectors.base.source
- Class org.apache.flink.cdc.connectors.base.source.IncrementalSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - configFactory
      
      SourceConfig.Factory<C extends SourceConfig> configFactory
    - dataSourceDialect
      
      DataSourceDialect<C extends SourceConfig> dataSourceDialect
    - deserializationSchema
      
      DebeziumDeserializationSchema<T> deserializationSchema
    - offsetFactory
      
      OffsetFactory offsetFactory
    - snapshotHooks
      
      SnapshotPhaseHooks snapshotHooks
    - sourceSplitSerializer
      
      SourceSplitSerializer sourceSplitSerializer
Package org.apache.flink.cdc.connectors.base.source.jdbc
- Class org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource extends IncrementalSource<T,JdbcSourceConfig> implements Serializable
Package org.apache.flink.cdc.connectors.base.source.meta.events
- Class org.apache.flink.cdc.connectors.base.source.meta.events.FinishedSnapshotSplitsAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - finishedSplits
      
      List<String> finishedSplits
- Class org.apache.flink.cdc.connectors.base.source.meta.events.FinishedSnapshotSplitsReportEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - finishedOffsets
      
      Map<String,Offset> finishedOffsets
- Class org.apache.flink.cdc.connectors.base.source.meta.events.FinishedSnapshotSplitsRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.base.source.meta.events.LatestFinishedSplitsNumberEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - latestFinishedSplitsNumber
      
      int latestFinishedSplitsNumber
- Class org.apache.flink.cdc.connectors.base.source.meta.events.LatestFinishedSplitsNumberRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitAssignedEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitMetaAssembledEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assignmentGeneration
      
      int assignmentGeneration
      
      The metadata assignment generation under which the reader assembled the split, echoed from the StreamSplitMetaEvents, or StreamSplitMetaAssembledEvent.COMPLETE_WITHOUT_META_GENERATION for an inline split. The coordinator releases only if this still matches its current generation, so a stale report from a re-assigned (failed-over) stream reader cannot trigger a premature release.
    - splitId
      
      String splitId
    - totalFinishedSplitSize
      
      int totalFinishedSplitSize
- Class org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitMetaEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - assignmentGeneration
      
      int assignmentGeneration
      
      Generation of the stream-split assignment these meta groups belong to (FLINK-40697). The reader echoes it back in StreamSplitMetaAssembledEvent so the coordinator can reject a stale assembled report from a failed reader attempt.
    - metaGroup
      
      List<byte[]> metaGroup
      
      The serialized metadata of stream split, it's serialized/deserialized by FinishedSnapshotSplitInfo.serialize() and OffsetDeserializerSerializer.deserialize(byte[]).
    - metaGroupId
      
      int metaGroupId
      
      The metadata of stream split is divided to multiple groups.
    - splitId
      
      String splitId
    - totalFinishedSplitSize
      
      int totalFinishedSplitSize
- Class org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitMetaRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - requestMetaGroupId
      
      int requestMetaGroupId
    - splitId
      
      String splitId
    - totalFinishedSplitSize
      
      int totalFinishedSplitSize
- Class org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitUpdateAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.base.source.meta.events.StreamSplitUpdateRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.base.source.meta.offset
- Class org.apache.flink.cdc.connectors.base.source.meta.offset.Offset extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
      
      Map<String,String> offset
- Class org.apache.flink.cdc.connectors.base.source.meta.offset.OffsetFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.base.source.meta.split
- Class org.apache.flink.cdc.connectors.base.source.meta.split.FinishedSnapshotSplitInfo extends Object implements Serializable
  - Serialized Fields
    - highWatermark
      
      Offset highWatermark
    - offsetFactory
      
      OffsetFactory offsetFactory
    - splitEnd
      
      Object[] splitEnd
    - splitId
      
      String splitId
    - splitStart
      
      Object[] splitStart
    - tableId
      
      io.debezium.relational.TableId tableId
- Class org.apache.flink.cdc.connectors.base.source.meta.split.SourceSplitSerializer extends Object implements Serializable
Package org.apache.flink.cdc.connectors.base.source.utils.hooks
- Class org.apache.flink.cdc.connectors.base.source.utils.hooks.SnapshotPhaseHooks extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - postHighWatermarkAction
      
      SnapshotPhaseHook postHighWatermarkAction
    - postLowWatermarkAction
      
      SnapshotPhaseHook postLowWatermarkAction
    - preHighWatermarkAction
      
      SnapshotPhaseHook preHighWatermarkAction
    - preLowWatermarkAction
      
      SnapshotPhaseHook preLowWatermarkAction
Package org.apache.flink.cdc.connectors.db2.source
- Class org.apache.flink.cdc.connectors.db2.source.Db2SourceBuilder.Db2IncrementalSource extends JdbcIncrementalSource<T> implements Serializable
Package org.apache.flink.cdc.connectors.db2.source.config
- Class org.apache.flink.cdc.connectors.db2.source.config.Db2SourceConfig extends JdbcSourceConfig implements Serializable
- Class org.apache.flink.cdc.connectors.db2.source.config.Db2SourceConfigFactory extends JdbcSourceConfigFactory implements Serializable
Package org.apache.flink.cdc.connectors.db2.source.dialect
- Class org.apache.flink.cdc.connectors.db2.source.dialect.Db2Dialect extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceConfig
      
      Db2SourceConfig sourceConfig
Package org.apache.flink.cdc.connectors.db2.source.offset
- Class org.apache.flink.cdc.connectors.db2.source.offset.LsnFactory extends OffsetFactory implements Serializable
- Class org.apache.flink.cdc.connectors.db2.source.offset.LsnOffset extends Offset implements Serializable
Package org.apache.flink.cdc.connectors.doris.sink
- Class org.apache.flink.cdc.connectors.doris.sink.DorisDataSink extends Object implements Serializable
  - Serialized Fields
    - configuration
      
      Configuration configuration
    - dorisOptions
      
      org.apache.doris.flink.cfg.DorisOptions dorisOptions
    - executionOptions
      
      org.apache.doris.flink.cfg.DorisExecutionOptions executionOptions
    - readOptions
      
      org.apache.doris.flink.cfg.DorisReadOptions readOptions
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.doris.sink.DorisEventSerializer extends Object implements Serializable
  - Serialized Fields
    - dorisConfig
      
      Configuration dorisConfig
    - objectMapper
      
      org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper objectMapper
    - pipelineZoneId
      
      java.time.ZoneId pipelineZoneId
      
      ZoneId from pipeline config to support timestamp with local time zone.
    - schemaMaps
      
      Map<TableId,Schema> schemaMaps
- Class org.apache.flink.cdc.connectors.doris.sink.DorisMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - config
      
      Configuration config
    - dorisOptions
      
      org.apache.doris.flink.cfg.DorisOptions dorisOptions
    - enabledSchemaEvolutionTypes
      
      Set<SchemaChangeEventType> enabledSchemaEvolutionTypes
    - schemaChangeManager
      
      DorisSchemaChangeManager schemaChangeManager
- Class org.apache.flink.cdc.connectors.doris.sink.DorisRowConverter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.doris.sink.DorisSchemaChangeManager extends org.apache.doris.flink.sink.schema.SchemaChangeManager implements Serializable
Package org.apache.flink.cdc.connectors.elasticsearch.config
- Class org.apache.flink.cdc.connectors.elasticsearch.config.ElasticsearchSinkOptions extends Object implements Serializable
  - Serialized Fields
    - maxBatchSize
      
      int maxBatchSize
    - maxBatchSizeInBytes
      
      long maxBatchSizeInBytes
    - maxBufferedRequests
      
      int maxBufferedRequests
    - maxInFlightRequests
      
      int maxInFlightRequests
    - maxRecordSizeInBytes
      
      long maxRecordSizeInBytes
    - maxTimeInBufferMS
      
      long maxTimeInBufferMS
    - networkConfig
      
      NetworkConfig networkConfig
    - password
      
      String password
    - shardingKey
      
      Map<TableId,String> shardingKey
    - shardingSeparator
      
      String shardingSeparator
    - username
      
      String username
    - version
      
      int version
Package org.apache.flink.cdc.connectors.elasticsearch.serializer
- Class org.apache.flink.cdc.connectors.elasticsearch.serializer.ElasticsearchEventSerializer extends Object implements Serializable
  - Serialized Fields
    - converterCache
      
      ConcurrentHashMap<TableId,List<ElasticsearchRowConverter.SerializationConverter>> converterCache
    - objectMapper
      
      com.fasterxml.jackson.databind.ObjectMapper objectMapper
    - pipelineZoneId
      
      java.time.ZoneId pipelineZoneId
      
      ZoneId from pipeline config to support timestamp with local time zone.
    - schemaMaps
      
      Map<TableId,Schema> schemaMaps
    - shardingKey
      
      Map<TableId,String> shardingKey
    - shardingSeparator
      
      String shardingSeparator
Package org.apache.flink.cdc.connectors.elasticsearch.sink
- Class org.apache.flink.cdc.connectors.elasticsearch.sink.ElasticsearchDataSink extends Object implements Serializable
  - Serialized Fields
    - esOptions
      
      ElasticsearchSinkOptions esOptions
      
      The Elasticsearch sink options.
    - zoneId
      
      java.time.ZoneId zoneId
      
      The time zone ID for handling time-related operations.
Package org.apache.flink.cdc.connectors.elasticsearch.v2
- Class org.apache.flink.cdc.connectors.elasticsearch.v2.Elasticsearch8AsyncSink extends org.apache.flink.connector.base.sink.AsyncSinkBaseAdapter<InputT,Operation> implements Serializable
  - Serialized Fields
    - networkConfig
      
      NetworkConfig networkConfig
- Class org.apache.flink.cdc.connectors.elasticsearch.v2.Elasticsearch8AsyncSinkBuilder.OperationConverter extends Object implements Serializable
  - Serialized Fields
    - converter
      
      org.apache.flink.connector.base.sink.writer.ElementConverter<T,co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant> converter
- Class org.apache.flink.cdc.connectors.elasticsearch.v2.NetworkConfig extends Object implements Serializable
  - Serialized Fields
    - headers
      
      List<org.apache.http.Header> headers
    - hosts
      
      List<org.apache.http.HttpHost> hosts
    - password
      
      String password
    - sslContextSupplier
      
      org.apache.flink.util.function.SerializableSupplier<SSLContext> sslContextSupplier
    - sslHostnameVerifier
      
      org.apache.flink.util.function.SerializableSupplier<HostnameVerifier> sslHostnameVerifier
    - username
      
      String username
- Class org.apache.flink.cdc.connectors.elasticsearch.v2.Operation extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bulkOperationVariant
      
      co.elastic.clients.elasticsearch.core.bulk.BulkOperationVariant bulkOperationVariant
Package org.apache.flink.cdc.connectors.fluss.sink
- Class org.apache.flink.cdc.connectors.fluss.sink.FlussEventSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.fluss.sink.FlussHashFunctionProvider extends Object implements Serializable
- Class org.apache.flink.cdc.connectors.fluss.sink.FlussMetaDataApplier extends Object implements Serializable
  - Serialized Fields
    - bucketKeysMap
      
      Map<String,List<String>> bucketKeysMap
    - bucketNumMap
      
      Map<String,Integer> bucketNumMap
    - enabledEventTypes
      
      Set<SchemaChangeEventType> enabledEventTypes
    - flussClientConfig
      
      org.apache.fluss.config.Configuration flussClientConfig
    - tableProperties
      
      Map<String,String> tableProperties
Package org.apache.flink.cdc.connectors.fluss.sink.v2
- Class org.apache.flink.cdc.connectors.fluss.sink.v2.FlussSink extends Object implements Serializable
  - Serialized Fields
    - flussConfig
      
      org.apache.fluss.config.Configuration flussConfig
    - serializer
      
      FlussEventSerializer<InputT> serializer
Package org.apache.flink.cdc.connectors.fluss.source
- Class org.apache.flink.cdc.connectors.fluss.source.FlussSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - deserializer
      
      FlussDeserializer<T> deserializer
    - discoverer
      
      TableDiscoverer discoverer
    - flussConfig
      
      org.apache.fluss.config.Configuration flussConfig
    - leaseContext
      
      LeaseContext leaseContext
    - offsetsInitializer
      
      org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer
    - scanDiscoveryIntervalMs
      
      long scanDiscoveryIntervalMs
    - sourceConfig
      
      Configuration sourceConfig
Package org.apache.flink.cdc.connectors.fluss.source.deserializer
- Class org.apache.flink.cdc.connectors.fluss.source.deserializer.FlussRecordDeserializer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.fluss.source.discover
- Class org.apache.flink.cdc.connectors.fluss.source.discover.FlussDefaultDiscoverer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.fluss.source.event
- Class org.apache.flink.cdc.connectors.fluss.source.event.FinishedKvSnapshotConsumeEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
      
      long checkpointId
    - tableBuckets
      
      Set<org.apache.fluss.metadata.TableBucket> tableBuckets
- Class org.apache.flink.cdc.connectors.fluss.source.event.TableRemovalAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - completedRemovalRequests
      
      Map<org.apache.fluss.metadata.TablePath,Long> completedRemovalRequests
- Class org.apache.flink.cdc.connectors.fluss.source.event.TableSubscriptionEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fencedTablePaths
      
      Set<org.apache.fluss.metadata.TablePath> fencedTablePaths
    - pendingRemovalRequests
      
      Map<org.apache.fluss.metadata.TablePath,Long> pendingRemovalRequests
    - subscribedTablePaths
      
      Set<org.apache.fluss.metadata.TablePath> subscribedTablePaths
Package org.apache.flink.cdc.connectors.fluss.source.reader
- Class org.apache.flink.cdc.connectors.fluss.source.reader.LeaseContext extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - kvSnapshotLeaseDurationMs
      
      long kvSnapshotLeaseDurationMs
    - kvSnapshotLeaseId
      
      String kvSnapshotLeaseId
Package org.apache.flink.cdc.connectors.hudi.sink
- Class org.apache.flink.cdc.connectors.hudi.sink.HudiDataSink extends Object implements Serializable
  - Serialized Fields
    - config
      
      Configuration config
    - schemaOperatorUid
      
      String schemaOperatorUid
- Class org.apache.flink.cdc.connectors.hudi.sink.HudiMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - catalogConfig
      
      org.apache.flink.configuration.Configuration catalogConfig
    - config
      
      Configuration config
Package org.apache.flink.cdc.connectors.hudi.sink.bucket
- Class org.apache.flink.cdc.connectors.hudi.sink.bucket.BucketAssignOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<BucketWrapper> implements Serializable
  - Serialized Fields
    - currentTaskNumber
      
      int currentTaskNumber
    - fieldGetterCache
      
      Map<TableId,List<RecordData.FieldGetter>> fieldGetterCache
      
      Field getter cache per table - lazily created and invalidated on schema changes.
    - keyGenCache
      
      Map<TableId,org.apache.hudi.sink.bulk.RowDataKeyGen> keyGenCache
      
      RowDataKeyGen cache per table for key and partition extraction.
    - numBuckets
      
      int numBuckets
    - schemaCache
      
      Map<TableId,Schema> schemaCache
      
      Cache of schemas per table for bucket calculation.
    - schemaOperatorUid
      
      String schemaOperatorUid
    - totalTasksNumber
      
      int totalTasksNumber
- Class org.apache.flink.cdc.connectors.hudi.sink.bucket.BucketWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bucket
      
      int bucket
    - event
      
      Event event
- Class org.apache.flink.cdc.connectors.hudi.sink.bucket.FlushEventAlignmentOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<BucketWrapper> implements Serializable
Package org.apache.flink.cdc.connectors.hudi.sink.coordinator
- Class org.apache.flink.cdc.connectors.hudi.sink.coordinator.MultiTableStreamWriteOperatorCoordinator.Provider extends Object implements Serializable
  - Serialized Fields
    - conf
      
      org.apache.flink.configuration.Configuration conf
    - operatorId
      
      org.apache.flink.runtime.jobgraph.OperatorID operatorId
Package org.apache.flink.cdc.connectors.hudi.sink.event
- Class org.apache.flink.cdc.connectors.hudi.sink.event.EnhancedWriteMetadataEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - originalEvent
      
      org.apache.hudi.sink.event.WriteMetadataEvent originalEvent
      
      The original event from the Hudi write function.
    - tablePath
      
      String tablePath
      
      The filesystem path of the Hudi table this event belongs to.
- Class org.apache.flink.cdc.connectors.hudi.sink.event.SchemaChangeOperatorEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - newSchema
      
      Schema newSchema
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.connectors.hudi.sink.event.TableAwareCorrespondent.CreateTableRequest extends TableAwareCorrespondent.SchemaChangeRequest implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.hudi.sink.event.TableAwareCorrespondent.MultiTableInstantTimeRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - checkpointId
      
      long checkpointId
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.connectors.hudi.sink.event.TableAwareCorrespondent.SchemaChangeRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schema
      
      Schema schema
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.connectors.hudi.sink.event.TableAwareCorrespondent.SchemaChangeResponse extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - success
      
      boolean success
    - tableId
      
      TableId tableId
Package org.apache.flink.cdc.connectors.hudi.sink.function
- Class org.apache.flink.cdc.connectors.hudi.sink.function.ExtendedBucketStreamWriteFunction extends org.apache.hudi.sink.bucket.BucketStreamWriteFunction implements Serializable
- Class org.apache.flink.cdc.connectors.hudi.sink.function.MultiTableEventStreamWriteFunction extends org.apache.hudi.sink.common.AbstractStreamWriteFunction<Event> implements Serializable
Package org.apache.flink.cdc.connectors.hudi.sink.operator
- Class org.apache.flink.cdc.connectors.hudi.sink.operator.MultiTableWriteOperator extends org.apache.hudi.sink.common.AbstractWriteOperator<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - multiTableWriteFunction
      
      MultiTableEventStreamWriteFunction multiTableWriteFunction
    - schemaOperatorUid
      
      String schemaOperatorUid
- Class org.apache.flink.cdc.connectors.hudi.sink.operator.MultiTableWriteOperatorFactory extends org.apache.flink.streaming.api.operators.SimpleUdfStreamOperatorFactory<org.apache.flink.table.data.RowData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - conf
      
      org.apache.flink.configuration.Configuration conf
    - writeOperator
      
      org.apache.hudi.sink.common.AbstractWriteOperator<I> writeOperator
Package org.apache.flink.cdc.connectors.hudi.sink.v2
- Class org.apache.flink.cdc.connectors.hudi.sink.v2.HudiSink extends Object implements Serializable
  - Serialized Fields
    - conf
      
      org.apache.flink.configuration.Configuration conf
    - schemaOperatorUid
      
      String schemaOperatorUid
Package org.apache.flink.cdc.connectors.iceberg.sink
- Class org.apache.flink.cdc.connectors.iceberg.sink.IcebergDataSink extends Object implements Serializable
  - Serialized Fields
    - catalogOptions
      
      Map<String,String> catalogOptions
    - compactionOptions
      
      CompactionOptions compactionOptions
    - hadoopConfOptions
      
      Map<String,String> hadoopConfOptions
    - jobIdPrefix
      
      String jobIdPrefix
    - partitionMaps
      
      Map<TableId,List<String>> partitionMaps
    - schemaOperatorUid
      
      String schemaOperatorUid
    - tableOptions
      
      Map<String,String> tableOptions
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.iceberg.sink.IcebergMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - catalogOptions
      
      Map<String,String> catalogOptions
    - enabledSchemaEvolutionTypes
      
      Set<SchemaChangeEventType> enabledSchemaEvolutionTypes
    - hadoopConfOptions
      
      Map<String,String> hadoopConfOptions
    - partitionMaps
      
      Map<TableId,List<String>> partitionMaps
    - tableOptions
      
      Map<String,String> tableOptions
Package org.apache.flink.cdc.connectors.iceberg.sink.v2
- Class org.apache.flink.cdc.connectors.iceberg.sink.v2.IcebergSink extends Object implements Serializable
  - Serialized Fields
    - catalogOptions
      
      Map<String,String> catalogOptions
    - compactionOptions
      
      CompactionOptions compactionOptions
    - hadoopConfOptions
      
      Map<String,String> hadoopConfOptions
    - jobId
      
      String jobId
    - operatorId
      
      String operatorId
    - tableOptions
      
      Map<String,String> tableOptions
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.iceberg.sink.v2.WriteResultWrapper extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - batchIndex
      
      int batchIndex
      
      Batch index within the checkpoint for this table; increments on each schema-change flush.
    - checkpointId
      
      long checkpointId
    - jobId
      
      String jobId
    - operatorId
      
      String operatorId
    - tableId
      
      TableId tableId
    - writeResult
      
      org.apache.iceberg.io.WriteResult writeResult
Package org.apache.flink.cdc.connectors.iceberg.sink.v2.compaction
- Class org.apache.flink.cdc.connectors.iceberg.sink.v2.compaction.CompactionOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<WriteResultWrapper>> implements Serializable
  - Serialized Fields
    - catalog
      
      org.apache.iceberg.catalog.Catalog catalog
    - catalogOptions
      
      Map<String,String> catalogOptions
    - compactedTables
      
      Set<TableId> compactedTables
    - compactExecutor
      
      ExecutorService compactExecutor
    - compactionOptions
      
      CompactionOptions compactionOptions
    - hadoopConfOptions
      
      Map<String,String> hadoopConfOptions
    - tableCommitTimes
      
      Map<TableId,Integer> tableCommitTimes
      
      store a list of MultiTableCommittable in one checkpoint.
    - throwable
      
      Throwable throwable
- Class org.apache.flink.cdc.connectors.iceberg.sink.v2.compaction.CompactionOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - commitInterval
      
      int commitInterval
    - enabled
      
      boolean enabled
    - parallelism
      
      int parallelism

Package org.apache.flink.cdc.connectors.kafka.json.canal

Class org.apache.flink.cdc.connectors.kafka.json.canal.CanalJsonSerializationSchema extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

context

org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context

encodeDecimalAsPlainNumber
```
boolean encodeDecimalAsPlainNumber
```
ignoreNullFields
```
boolean ignoreNullFields
```
jsonSerializers
```
Map<TableId,TableSchemaInfo> jsonSerializers
```
The serializer to serialize Canal JSON data.
mapNullKeyLiteral
```
String mapNullKeyLiteral
```

mapNullKeyMode

org.apache.flink.formats.json.JsonFormatOptions.MapNullKeyMode mapNullKeyMode

timestampFormat

org.apache.flink.formats.common.TimestampFormat timestampFormat

zoneId
```
java.time.ZoneId zoneId
```

Package org.apache.flink.cdc.connectors.kafka.json.debezium
- Class org.apache.flink.cdc.connectors.kafka.json.debezium.DebeziumJsonRowDataSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - encodeDecimalAsPlainNumber
      
      boolean encodeDecimalAsPlainNumber
      
      Flag indicating whether to serialize all decimals as plain numbers.
    - ignoreNullFields
      
      boolean ignoreNullFields
      
      Flag indicating whether to ignore null fields.
    - isIncludedDebeziumSchema
      
      boolean isIncludedDebeziumSchema
    - mapNullKeyLiteral
      
      String mapNullKeyLiteral
      
      The string literal when handling mode for map null key LITERAL.
    - mapNullKeyMode
      
      org.apache.flink.formats.json.JsonFormatOptions.MapNullKeyMode mapNullKeyMode
      
      The handling mode when serializing null keys for map data.
    - rowType
      
      org.apache.flink.table.types.logical.RowType rowType
      
      RowType to generate the runtime converter.
    - runtimeConverter
      
      org.apache.flink.formats.json.RowDataToJsonConverters.RowDataToJsonConverter runtimeConverter
      
      The converter that converts internal data formats to JsonNode.
    - timestampFormat
      
      org.apache.flink.formats.common.TimestampFormat timestampFormat
      
      Timestamp format specification which is used to parse timestamp.
- Class org.apache.flink.cdc.connectors.kafka.json.debezium.DebeziumJsonSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - context
      
      org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context
    - encodeDecimalAsPlainNumber
      
      boolean encodeDecimalAsPlainNumber
    - ignoreNullFields
      
      boolean ignoreNullFields
    - isIncludedDebeziumSchema
      
      boolean isIncludedDebeziumSchema
    - jsonConverter
      
      org.apache.kafka.connect.json.JsonConverter jsonConverter
    - jsonSerializers
      
      Map<TableId,TableSchemaInfo> jsonSerializers
      
      A map of TableId and its SerializationSchema to serialize Debezium JSON data.
    - mapNullKeyLiteral
      
      String mapNullKeyLiteral
    - mapNullKeyMode
      
      org.apache.flink.formats.json.JsonFormatOptions.MapNullKeyMode mapNullKeyMode
    - schemaMap
      
      Map<TableId,String> schemaMap
    - timestampFormat
      
      org.apache.flink.formats.common.TimestampFormat timestampFormat
    - zoneId
      
      java.time.ZoneId zoneId
Package org.apache.flink.cdc.connectors.kafka.serialization
- Class org.apache.flink.cdc.connectors.kafka.serialization.CsvSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - context
      
      org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context
    - csvSerializers
      
      Map<TableId,TableSchemaInfo> csvSerializers
      
      A map of TableId and its SerializationSchema to serialize Debezium JSON data.
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.kafka.serialization.JsonSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - context
      
      org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext context
    - encodeDecimalAsPlainNumber
      
      boolean encodeDecimalAsPlainNumber
    - ignoreNullFields
      
      boolean ignoreNullFields
    - jsonSerializers
      
      Map<TableId,TableSchemaInfo> jsonSerializers
      
      A map of TableId and its SerializationSchema to serialize Debezium JSON data.
    - mapNullKeyLiteral
      
      String mapNullKeyLiteral
    - mapNullKeyMode
      
      org.apache.flink.formats.json.JsonFormatOptions.MapNullKeyMode mapNullKeyMode
    - timestampFormat
      
      org.apache.flink.formats.common.TimestampFormat timestampFormat
    - zoneId
      
      java.time.ZoneId zoneId
Package org.apache.flink.cdc.connectors.kafka.sink
- Class org.apache.flink.cdc.connectors.kafka.sink.KafkaMetaDataApplier extends Object implements Serializable
  - Serialized Fields
    - enabledEventTypes
      
      Set<SchemaChangeEventType> enabledEventTypes
- Class org.apache.flink.cdc.connectors.kafka.sink.PipelineKafkaRecordSerializationSchema extends Object implements Serializable
  - Serialized Fields
    - addTableToHeaderEnabled
      
      boolean addTableToHeaderEnabled
    - customHeaders
      
      Map<String,String> customHeaders
    - keySerialization
      
      org.apache.flink.api.common.serialization.SerializationSchema<Event> keySerialization
    - mappingRuleString
      
      String mappingRuleString
    - partition
      
      Integer partition
    - selectorsToTopicMap
      
      Map<Selectors,String> selectorsToTopicMap
    - tableIdToTopicCache
      
      Map<TableId,String> tableIdToTopicCache
    - unifiedTopic
      
      String unifiedTopic
    - valueSerialization
      
      org.apache.flink.api.common.serialization.SerializationSchema<Event> valueSerialization
Package org.apache.flink.cdc.connectors.maxcompute
- Class org.apache.flink.cdc.connectors.maxcompute.MaxComputeMetadataApplier extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - maxComputeOptions
      
      MaxComputeOptions maxComputeOptions
Package org.apache.flink.cdc.connectors.maxcompute.common
- Class org.apache.flink.cdc.connectors.maxcompute.common.FlinkOdpsException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.maxcompute.common.SessionIdentifier extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - partitionName
      
      String partitionName
    - project
      
      String project
    - schema
      
      String schema
    - sessionId
      
      String sessionId
      
      sessionId not calculate in hashcode and equals.
    - table
      
      String table
- Class org.apache.flink.cdc.connectors.maxcompute.common.UncheckedOdpsException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - cause
      
      com.aliyun.odps.OdpsException cause
Package org.apache.flink.cdc.connectors.maxcompute.coordinator
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.SessionManageCoordinatedOperatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - options
      
      MaxComputeOptions options
    - schemaOperatorUid
      
      String schemaOperatorUid
    - writeOptions
      
      MaxComputeWriteOptions writeOptions
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.SessionManageCoordinator.SessionManageCoordinatorProvider extends Object implements Serializable
  - Serialized Fields
    - operatorID
      
      org.apache.flink.runtime.jobgraph.OperatorID operatorID
    - operatorName
      
      String operatorName
    - options
      
      MaxComputeOptions options
    - writeOptions
      
      MaxComputeWriteOptions writeOptions
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.SessionManageOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - options
      
      MaxComputeOptions options
    - schemaOperatorUid
      
      org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorUid
Package org.apache.flink.cdc.connectors.maxcompute.coordinator.message
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.message.CommitSessionRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - operatorIndex
      
      int operatorIndex
    - sessionId
      
      String sessionId
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.message.CommitSessionResponse extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - success
      
      boolean success
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.message.CreateSessionRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - identifier
      
      SessionIdentifier identifier
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.message.CreateSessionResponse extends Object implements Serializable
  - Serialized Fields
    - sessionId
      
      String sessionId
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.message.SyncRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - operatorIndex
      
      int operatorIndex
- Class org.apache.flink.cdc.connectors.maxcompute.coordinator.message.WaitForFlushSuccessRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - operatorIndex
      
      int operatorIndex
Package org.apache.flink.cdc.connectors.maxcompute.options
- Class org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - accessId
      
      String accessId
    - accessKey
      
      String accessKey
    - bucketsNum
      
      int bucketsNum
    - endpoint
      
      String endpoint
    - project
      
      String project
    - quotaName
      
      String quotaName
    - schemaOperatorUid
      
      String schemaOperatorUid
    - stsToken
      
      String stsToken
    - supportSchema
      
      boolean supportSchema
    - tunnelEndpoint
      
      String tunnelEndpoint
- Class org.apache.flink.cdc.connectors.maxcompute.options.MaxComputeWriteOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - compressAlgorithm
      
      String compressAlgorithm
    - flushConcurrent
      
      int flushConcurrent
    - maxBufferSize
      
      long maxBufferSize
    - numCommitThread
      
      int numCommitThread
    - slotBufferSize
      
      long slotBufferSize
Package org.apache.flink.cdc.connectors.maxcompute.sink
- Class org.apache.flink.cdc.connectors.maxcompute.sink.MaxComputeEventSink extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - options
      
      MaxComputeOptions options
    - writeOptions
      
      MaxComputeWriteOptions writeOptions
- Class org.apache.flink.cdc.connectors.maxcompute.sink.MaxComputeHashFunctionProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bucketSize
      
      int bucketSize
Package org.apache.flink.cdc.connectors.mongodb.source
- Class org.apache.flink.cdc.connectors.mongodb.source.MongoDBSource extends IncrementalSource<T,MongoDBSourceConfig> implements Serializable
  
  serialVersionUID:
  
  1L

Package org.apache.flink.cdc.connectors.mongodb.source.config

Class org.apache.flink.cdc.connectors.mongodb.source.config.MongoDBSourceConfig extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

assignUnboundedChunkFirst
```
boolean assignUnboundedChunkFirst
```
batchSize
```
int batchSize
```
closeIdleReaders
```
boolean closeIdleReaders
```
collectionList
```
List<String> collectionList
```
connectionString
```
String connectionString
```
databaseList
```
List<String> databaseList
```
disableCursorTimeout
```
boolean disableCursorTimeout
```
enableFullDocPrePostImage
```
boolean enableFullDocPrePostImage
```
heartbeatIntervalMillis
```
int heartbeatIntervalMillis
```
hosts
```
String hosts
```
isScanNewlyAddedTableEnabled
```
boolean isScanNewlyAddedTableEnabled
```
password
```
String password
```
pollAwaitTimeMillis
```
int pollAwaitTimeMillis
```
pollMaxBatchSize
```
int pollMaxBatchSize
```
releaseSnapshotMetadataEnabled
```
boolean releaseSnapshotMetadataEnabled
```
samplesPerChunk
```
int samplesPerChunk
```
scheme
```
String scheme
```
skipSnapshotBackfill
```
boolean skipSnapshotBackfill
```
splitMetaGroupSize
```
int splitMetaGroupSize
```
splitSizeMB
```
int splitSizeMB
```
sslEnabled
```
boolean sslEnabled
```
sslInvalidHostnameAllowed
```
boolean sslInvalidHostnameAllowed
```
sslKeyStore
```
String sslKeyStore
```
sslKeyStorePassword
```
String sslKeyStorePassword
```
sslKeyStoreType
```
String sslKeyStoreType
```
sslTrustStore
```
String sslTrustStore
```
sslTrustStorePassword
```
String sslTrustStorePassword
```
sslTrustStoreType
```
String sslTrustStoreType
```
startupOptions
```
StartupOptions startupOptions
```
updateLookup
```
boolean updateLookup
```
username
```
String username
```

Class org.apache.flink.cdc.connectors.mongodb.source.config.MongoDBSourceConfigFactory extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

assignUnboundedChunkFirst
```
boolean assignUnboundedChunkFirst
```
batchSize
```
Integer batchSize
```
closeIdleReaders
```
boolean closeIdleReaders
```
collectionList
```
List<String> collectionList
```
connectionOptions
```
String connectionOptions
```
databaseList
```
List<String> databaseList
```
disableCursorTimeout
```
boolean disableCursorTimeout
```
enableFullDocPrePostImage
```
boolean enableFullDocPrePostImage
```
heartbeatIntervalMillis
```
Integer heartbeatIntervalMillis
```
hosts
```
String hosts
```
password
```
String password
```
pollAwaitTimeMillis
```
Integer pollAwaitTimeMillis
```
pollMaxBatchSize
```
Integer pollMaxBatchSize
```
releaseSnapshotMetadataEnabled
```
boolean releaseSnapshotMetadataEnabled
```
samplesPerChunk
```
Integer samplesPerChunk
```
scanNewlyAddedTableEnabled
```
boolean scanNewlyAddedTableEnabled
```
scheme
```
String scheme
```
skipSnapshotBackfill
```
boolean skipSnapshotBackfill
```
splitMetaGroupSize
```
Integer splitMetaGroupSize
```
splitSizeMB
```
Integer splitSizeMB
```
sslEnabled
```
boolean sslEnabled
```
sslInvalidHostnameAllowed
```
boolean sslInvalidHostnameAllowed
```
sslKeyStore
```
String sslKeyStore
```
sslKeyStorePassword
```
String sslKeyStorePassword
```
sslKeyStoreType
```
String sslKeyStoreType
```
sslTrustStore
```
String sslTrustStore
```
sslTrustStorePassword
```
String sslTrustStorePassword
```
sslTrustStoreType
```
String sslTrustStoreType
```
startupOptions
```
StartupOptions startupOptions
```
updateLookup
```
boolean updateLookup
```
username
```
String username
```

Package org.apache.flink.cdc.connectors.mongodb.source.dialect
- Class org.apache.flink.cdc.connectors.mongodb.source.dialect.MongoDBDialect extends Object implements Serializable
  - Serialized Fields
    - cache
      
      Map<MongoDBSourceConfig,CollectionDiscoveryUtils.CollectionDiscoveryInfo> cache
Package org.apache.flink.cdc.connectors.mongodb.source.offset
- Class org.apache.flink.cdc.connectors.mongodb.source.offset.ChangeStreamDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - collection
      
      String collection
    - database
      
      String database
    - databaseRegex
      
      Pattern databaseRegex
    - namespaceRegex
      
      Pattern namespaceRegex
- Class org.apache.flink.cdc.connectors.mongodb.source.offset.ChangeStreamOffset extends Offset implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.mongodb.source.offset.ChangeStreamOffsetFactory extends OffsetFactory implements Serializable
Package org.apache.flink.cdc.connectors.mongodb.source.utils
- Class org.apache.flink.cdc.connectors.mongodb.source.utils.CollectionDiscoveryUtils.CollectionDiscoveryInfo extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - discoveredCollections
      
      List<String> discoveredCollections
    - discoveredDatabases
      
      List<String> discoveredDatabases
Package org.apache.flink.cdc.connectors.mongodb.table
- Class org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1750787080613035184L
  - Serialized Fields
    - appendMetadataCollector
      
      AppendMetadataCollector appendMetadataCollector
      
      A wrapped output collector which is used to append metadata columns after physical columns.
    - hasMetadata
      
      boolean hasMetadata
      
      Whether the deserializer needs to handle metadata columns.
    - localTimeZone
      
      java.time.ZoneId localTimeZone
      
      Local Time zone.
    - physicalConverter
      
      org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorDeserializationSchema.DeserializationRuntimeConverter physicalConverter
      
      Runtime converter that converts ChangeStreamDocuments into RowData consisted of physical column values.
    - resultTypeInfo
      
      org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo
      
      TypeInformation of the produced RowData.
- Class org.apache.flink.cdc.connectors.mongodb.table.MongoDBConnectorFullChangelogDeserializationSchema extends MongoDBConnectorDeserializationSchema implements Serializable
  
  serialVersionUID:
  
  1750787080613035184L
Package org.apache.flink.cdc.connectors.mysql
- Class org.apache.flink.cdc.connectors.mysql.MySqlValidator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dbzProperties
      
      Properties dbzProperties
    - sourceConfig
      
      MySqlSourceConfig sourceConfig
- Class org.apache.flink.cdc.connectors.mysql.SeekBinlogToTimestampFilter extends Object implements Serializable
  
  serialVersionUID:
  
  -4450118969976653497L
  - Serialized Fields
    - serializer
      
      DebeziumDeserializationSchema<T> serializer
    - startupTimestampMillis
      
      long startupTimestampMillis
Package org.apache.flink.cdc.connectors.mysql.debezium.task.context.exception
- Class org.apache.flink.cdc.connectors.mysql.debezium.task.context.exception.SchemaOutOfSyncException extends Exception implements Serializable
Package org.apache.flink.cdc.connectors.mysql.source
- Class org.apache.flink.cdc.connectors.mysql.source.MySqlEventDeserializer extends DebeziumEventDeserializationSchema implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includeComments
      
      boolean includeComments
    - includeSchemaChanges
      
      boolean includeSchemaChanges
    - isTableIdCaseInsensitive
      
      boolean isTableIdCaseInsensitive
    - readableMetadataList
      
      List<MySqlReadableMetadata> readableMetadataList
    - tinyInt1isBit
      
      boolean tinyInt1isBit
- Class org.apache.flink.cdc.connectors.mysql.source.MySqlSchemaDataTypeInference extends DebeziumSchemaDataTypeInference implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.mysql.source.MySqlSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - configFactory
      
      MySqlSourceConfigFactory configFactory
    - deserializationSchema
      
      DebeziumDeserializationSchema<T> deserializationSchema
    - recordEmitterSupplier
      
      org.apache.flink.cdc.connectors.mysql.source.MySqlSource.RecordEmitterSupplier<T> recordEmitterSupplier
    - snapshotHooks
      
      SnapshotPhaseHooks snapshotHooks
- Class org.apache.flink.cdc.connectors.mysql.source.OpTsMetadataColumn extends Object implements Serializable

Package org.apache.flink.cdc.connectors.mysql.source.config

Class org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceConfig extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

assignUnboundedChunkFirst
```
boolean assignUnboundedChunkFirst
```

chunkKeyColumns

Map<org.apache.flink.table.catalog.ObjectPath,String> chunkKeyColumns

closeIdleReaders
```
boolean closeIdleReaders
```
connectionPoolSize
```
int connectionPoolSize
```
connectMaxRetries
```
int connectMaxRetries
```
connectTimeout
```
java.time.Duration connectTimeout
```
databaseList
```
List<String> databaseList
```

dbzConfiguration

io.debezium.config.Configuration dbzConfiguration

dbzMySqlConfig

io.debezium.connector.mysql.MySqlConnectorConfig dbzMySqlConfig

dbzProperties
```
Properties dbzProperties
```
distributionFactorLower
```
double distributionFactorLower
```
distributionFactorUpper
```
double distributionFactorUpper
```
excludeTableList
```
String excludeTableList
```
fetchSize
```
int fetchSize
```
hostname
```
String hostname
```
includeHeartbeatEvents
```
boolean includeHeartbeatEvents
```
includeSchemaChanges
```
boolean includeSchemaChanges
```

includeTransactionMetadataEvents

boolean includeTransactionMetadataEvents

jdbcProperties
```
Properties jdbcProperties
```
parseOnLineSchemaChanges
```
boolean parseOnLineSchemaChanges
```
password
```
String password
```
port
```
int port
```
releaseSnapshotMetadataEnabled
```
boolean releaseSnapshotMetadataEnabled
```
scanNewlyAddedTableEnabled
```
boolean scanNewlyAddedTableEnabled
```
serverIdRange
```
ServerIdRange serverIdRange
```
serverTimeZone
```
String serverTimeZone
```
skipSnapshotBackfill
```
boolean skipSnapshotBackfill
```
splitMetaGroupSize
```
int splitMetaGroupSize
```
splitSize
```
int splitSize
```
startupOptions
```
StartupOptions startupOptions
```
tableList
```
List<String> tableList
```
treatTinyInt1AsBoolean
```
boolean treatTinyInt1AsBoolean
```
username
```
String username
```

Class org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory extends Object implements Serializable

serialVersionUID:: 1L

Serialized Fields

assignUnboundedChunkFirst
```
boolean assignUnboundedChunkFirst
```

chunkKeyColumns

Map<org.apache.flink.table.catalog.ObjectPath,String> chunkKeyColumns

closeIdleReaders
```
boolean closeIdleReaders
```
connectionPoolSize
```
int connectionPoolSize
```
connectMaxRetries
```
int connectMaxRetries
```
connectTimeout
```
java.time.Duration connectTimeout
```
databaseList
```
List<String> databaseList
```
dbzProperties
```
Properties dbzProperties
```
distributionFactorLower
```
double distributionFactorLower
```
distributionFactorUpper
```
double distributionFactorUpper
```
excludeTableList
```
String excludeTableList
```
fetchSize
```
int fetchSize
```
heartbeatInterval
```
java.time.Duration heartbeatInterval
```
hostname
```
String hostname
```
includeHeartbeatEvents
```
boolean includeHeartbeatEvents
```
includeSchemaChanges
```
boolean includeSchemaChanges
```

includeTransactionMetadataEvents

boolean includeTransactionMetadataEvents

jdbcProperties
```
Properties jdbcProperties
```
parseOnLineSchemaChanges
```
boolean parseOnLineSchemaChanges
```
password
```
String password
```
port
```
int port
```
releaseSnapshotMetadataEnabled
```
boolean releaseSnapshotMetadataEnabled
```
scanNewlyAddedTableEnabled
```
boolean scanNewlyAddedTableEnabled
```
serverIdRange
```
ServerIdRange serverIdRange
```
serverTimeZone
```
String serverTimeZone
```
skipSnapshotBackfill
```
boolean skipSnapshotBackfill
```
splitMetaGroupSize
```
int splitMetaGroupSize
```
splitSize
```
int splitSize
```
startupOptions
```
StartupOptions startupOptions
```
tableList
```
List<String> tableList
```
treatTinyInt1AsBoolean
```
boolean treatTinyInt1AsBoolean
```
useLegacyJsonFormat
```
boolean useLegacyJsonFormat
```
username
```
String username
```

Class org.apache.flink.cdc.connectors.mysql.source.config.ServerIdRange extends Object implements Serializable

serialVersionUID:

1L
- Serialized Fields
  - endServerId
```
int endServerId
```
    End of the range (inclusive).
  - startServerId
```
int startServerId
```
    Start of the range (inclusive).

Package org.apache.flink.cdc.connectors.mysql.source.connection
- Class org.apache.flink.cdc.connectors.mysql.source.connection.ConnectionPoolId extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - host
      
      String host
    - port
      
      int port
    - username
      
      String username
Package org.apache.flink.cdc.connectors.mysql.source.events
- Class org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitAssignedEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitMetaAssembledEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - binlogAssignmentGeneration
      
      long binlogAssignmentGeneration
- Class org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - binlogAssignmentGeneration
      
      long binlogAssignmentGeneration
      
      The binlog assignment generation current at the coordinator when this meta group was served. The reader echoes it back in BinlogSplitMetaAssembledEvent so the coordinator can tell a fresh assembled signal from a stale one left by a failed reader attempt.
    - metaGroup
      
      List<byte[]> metaGroup
      
      The serialized metadata of binlog split, it's serialized/deserialize by FinishedSnapshotSplitInfo.serialize(FinishedSnapshotSplitInfo) and FinishedSnapshotSplitInfo.deserialize(byte[]).
    - metaGroupId
      
      int metaGroupId
      
      The metadata of binlog split is divided to multiple groups.
    - splitId
      
      String splitId
    - totalFinishedSplitSize
      
      int totalFinishedSplitSize
- Class org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitMetaRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - requestMetaGroupId
      
      int requestMetaGroupId
    - splitId
      
      String splitId
    - totalFinishedSplitSize
      
      int totalFinishedSplitSize
- Class org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitUpdateAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.mysql.source.events.BinlogSplitUpdateRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - finishedSplits
      
      List<String> finishedSplits
- Class org.apache.flink.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsReportEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - finishedOffsets
      
      Map<String,BinlogOffset> finishedOffsets
- Class org.apache.flink.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.mysql.source.events.LatestFinishedSplitsNumberEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - latestFinishedSplitsNumber
      
      int latestFinishedSplitsNumber
- Class org.apache.flink.cdc.connectors.mysql.source.events.LatestFinishedSplitsNumberRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.mysql.source.offset
- Class org.apache.flink.cdc.connectors.mysql.source.offset.BinlogOffset extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
      
      Map<String,String> offset
Package org.apache.flink.cdc.connectors.mysql.source.utils.hooks
- Class org.apache.flink.cdc.connectors.mysql.source.utils.hooks.SnapshotPhaseHooks extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - postHighWatermarkAction
      
      SnapshotPhaseHook postHighWatermarkAction
    - postLowWatermarkAction
      
      SnapshotPhaseHook postLowWatermarkAction
    - preHighWatermarkAction
      
      SnapshotPhaseHook preHighWatermarkAction
    - preLowWatermarkAction
      
      SnapshotPhaseHook preLowWatermarkAction
Package org.apache.flink.cdc.connectors.mysql.table
- Class org.apache.flink.cdc.connectors.mysql.table.StartupOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - binlogOffset
      
      BinlogOffset binlogOffset
    - startupMode
      
      StartupMode startupMode
Package org.apache.flink.cdc.connectors.oceanbase.catalog
- Class org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalog extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - connectionProvider
      
      com.oceanbase.connector.flink.connection.OceanBaseConnectionProvider connectionProvider
    - connectorOptions
      
      com.oceanbase.connector.flink.OceanBaseConnectorOptions connectorOptions
- Class org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseCatalogException extends RuntimeException implements Serializable
- Class org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseColumn extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnComment
      
      String columnComment
      
      The column comment. COLUMN_COMMENT in information_schema.COLUMNS.
    - columnName
      
      String columnName
      
      The name of the column.
    - columnSize
      
      Integer columnSize
      
      The column size. For numeric data, this is the maximum precision. For character data, this is the length in characters. For other data types, this is null.
    - dataType
      
      String dataType
      
      The column data type.
    - defaultValue
      
      String defaultValue
      
      The default value for the column.
    - isNullable
      
      boolean isNullable
      
      The column nullability.
    - numericScale
      
      Integer numericScale
      
      The number of fractional digits for numeric data. This is null for other data types. NUMBER_SCALE in information_schema.COLUMNS.
    - ordinalPosition
      
      int ordinalPosition
      
      The position of the column within the table (starting at 0).
- Class org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseMySQLCatalog extends OceanBaseCatalog implements Serializable
- Class org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseOracleCatalog extends OceanBaseCatalog implements Serializable
Package org.apache.flink.cdc.connectors.oceanbase.sink
- Class org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseDataSink extends Object implements Serializable
  - Serialized Fields
    - connectorOptions
      
      com.oceanbase.connector.flink.OceanBaseConnectorOptions connectorOptions
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseEventSerializationSchema extends Object implements Serializable
  - Serialized Fields
    - cache
      
      org.apache.flink.shaded.guava31.com.google.common.cache.Cache<Schema,List<org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseRowConvert.SerializationConverter>> cache
    - pipelineZoneId
      
      java.time.ZoneId pipelineZoneId
      
      ZoneId from pipeline config to support timestamp with local time zone.
    - schemaMaps
      
      Map<TableId,Schema> schemaMaps
- Class org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - catalog
      
      OceanBaseCatalog catalog
- Class org.apache.flink.cdc.connectors.oceanbase.sink.OceanBaseRowConvert extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.oracle
- Class org.apache.flink.cdc.connectors.oracle.OracleValidator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - properties
      
      Properties properties
Package org.apache.flink.cdc.connectors.oracle.source
- Class org.apache.flink.cdc.connectors.oracle.source.OracleDialect extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.oracle.source.OracleEventDeserializer extends DebeziumEventDeserializationSchema implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includeSchemaChanges
      
      boolean includeSchemaChanges
    - readableMetadataList
      
      List<OracleReadableMetaData> readableMetadataList
- Class org.apache.flink.cdc.connectors.oracle.source.OracleSchemaDataTypeInference extends DebeziumSchemaDataTypeInference implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.oracle.source.OracleSourceBuilder.OracleIncrementalSource extends JdbcIncrementalSource<T> implements Serializable
Package org.apache.flink.cdc.connectors.oracle.source.config
- Class org.apache.flink.cdc.connectors.oracle.source.config.OracleSourceConfig extends JdbcSourceConfig implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - url
      
      String url
- Class org.apache.flink.cdc.connectors.oracle.source.config.OracleSourceConfigFactory extends JdbcSourceConfigFactory implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schemaList
      
      List<String> schemaList
    - url
      
      String url
Package org.apache.flink.cdc.connectors.oracle.source.meta.offset
- Class org.apache.flink.cdc.connectors.oracle.source.meta.offset.RedoLogOffset extends Offset implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.oracle.source.meta.offset.RedoLogOffsetFactory extends OffsetFactory implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.connectors.oracle.source.reader
- Class org.apache.flink.cdc.connectors.oracle.source.reader.OracleTableSourceReader extends OracleSourceBuilder.OracleIncrementalSource<Event> implements Serializable
  - Serialized Fields
    - sourceConfig
      
      OracleSourceConfig sourceConfig
Package org.apache.flink.cdc.connectors.paimon.sink
- Class org.apache.flink.cdc.connectors.paimon.sink.PaimonDataSink extends Object implements Serializable
  - Serialized Fields
    - commitUser
      
      String commitUser
    - options
      
      org.apache.paimon.options.Options options
    - partitionMaps
      
      Map<TableId,List<String>> partitionMaps
    - schemaOperatorUid
      
      String schemaOperatorUid
    - serializer
      
      PaimonRecordSerializer<Event> serializer
    - tableOptions
      
      Map<String,String> tableOptions
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.paimon.sink.PaimonHashFunction extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - channelComputer
      
      org.apache.paimon.flink.sink.RowAssignerChannelComputer channelComputer
    - fieldGetters
      
      List<RecordData.FieldGetter> fieldGetters
    - parallelism
      
      int parallelism
- Class org.apache.flink.cdc.connectors.paimon.sink.PaimonHashFunctionProvider extends Object implements Serializable
  - Serialized Fields
    - parallelism
      
      int parallelism
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.paimon.sink.PaimonMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - catalogOptions
      
      org.apache.paimon.options.Options catalogOptions
    - enabledSchemaEvolutionTypes
      
      Set<SchemaChangeEventType> enabledSchemaEvolutionTypes
    - partitionMaps
      
      Map<TableId,List<String>> partitionMaps
    - tableOptions
      
      Map<String,String> tableOptions
Package org.apache.flink.cdc.connectors.paimon.sink.v2
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.MultiTableCommittableChannelComputer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonEventSink extends PaimonSink<Event> implements Serializable
  - Serialized Fields
    - schemaOperatorUid
      
      String schemaOperatorUid
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonRecordEventSerializer extends Object implements Serializable
  - Serialized Fields
    - options
      
      org.apache.paimon.options.Options options
    - schemaMaps
      
      Map<TableId,TableSchemaInfo> schemaMaps
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonSink extends Object implements Serializable
  - Serialized Fields
    - catalogOptions
      
      org.apache.paimon.options.Options catalogOptions
    - commitUser
      
      String commitUser
      
      The commitUser should be restored in state and restore it in writer.
    - serializer
      
      PaimonRecordSerializer<InputT> serializer
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonWriterHelper.BinaryFieldDataGetter extends Object implements Serializable
  - Serialized Fields
    - dataTypeRoot
      
      DataTypeRoot dataTypeRoot
    - fieldPos
      
      int fieldPos
    - rowFieldCount
      
      int rowFieldCount
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.PreCommitOperator extends org.apache.flink.streaming.api.operators.AbstractStreamOperator<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<org.apache.paimon.flink.sink.MultiTableCommittable>> implements Serializable
  - Serialized Fields
    - catalog
      
      org.apache.paimon.catalog.Catalog catalog
    - catalogOptions
      
      org.apache.paimon.options.Options catalogOptions
    - commitUser
      
      String commitUser
    - multiTableCommittables
      
      List<org.apache.paimon.flink.sink.MultiTableCommittable> multiTableCommittables
      
      store a list of MultiTableCommittable in one checkpoint.
    - storeMultiCommitter
      
      org.apache.paimon.flink.sink.StoreMultiCommitter storeMultiCommitter
Package org.apache.flink.cdc.connectors.paimon.sink.v2.blob
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.blob.BlobWriteContext extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - blobDescriptorFields
      
      Set<String> blobDescriptorFields
      
      Fields configured with blob-descriptor-field (Mode 2).
    - blobFields
      
      Set<String> blobFields
      
      Fields that should be converted to BLOB type.
    - isCaseSensitive
      
      boolean isCaseSensitive
Package org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.BucketAssignOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  - Serialized Fields
    - bucketAssignerMap
      
      Map<TableId,org.apache.flink.api.java.tuple.Tuple4<org.apache.paimon.table.BucketMode,org.apache.paimon.table.sink.RowKeyExtractor,org.apache.paimon.index.BucketAssigner,org.apache.paimon.table.sink.RowPartitionKeyExtractor>> bucketAssignerMap
    - catalog
      
      org.apache.paimon.catalog.Catalog catalog
    - catalogOptions
      
      org.apache.paimon.options.Options catalogOptions
    - commitUser
      
      String commitUser
    - currentTaskNumber
      
      int currentTaskNumber
    - schemaDerivator
      
      SchemaDerivator schemaDerivator
    - schemaMaps
      
      Map<TableId,org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.BucketAssignOperator.MixedSchemaInfo> schemaMaps
    - schemaOperatorUid
      
      String schemaOperatorUid
    - totalTasksNumber
      
      int totalTasksNumber
    - zoneId
      
      java.time.ZoneId zoneId
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.BucketWrapperChangeEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - bucket
      
      int bucket
    - innerEvent
      
      ChangeEvent innerEvent
    - partition
      
      int partition
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.BucketWrapperEventSerializer extends TypeSerializerSingleton<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - enumSerializer
      
      EnumSerializer<org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.BucketWrapperEventSerializer.EventClass> enumSerializer
    - eventSerializer
      
      EventSerializer eventSerializer
    - schemaChangeEventTypeEnumSerializer
      
      EnumSerializer<SchemaChangeEventType> schemaChangeEventTypeEnumSerializer
    - tableIdListSerializer
      
      ListSerializer<TableId> tableIdListSerializer
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.BucketWrapperEventTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<Event> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.paimon.sink.v2.bucket.FlushEventAlignmentOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
Package org.apache.flink.cdc.connectors.postgres.source
- Class org.apache.flink.cdc.connectors.postgres.source.DatabaseNameMetadataColumn extends Object implements Serializable
- Class org.apache.flink.cdc.connectors.postgres.source.OpTsMetadataColumn extends Object implements Serializable
- Class org.apache.flink.cdc.connectors.postgres.source.PostgresDataSource.PostgresPipelineSource extends PostgresSourceBuilder.PostgresIncrementalSource<T> implements Serializable
  - Serialized Fields
    - dataSourceDialect
      
      PostgresDialect dataSourceDialect
    - sourceConfig
      
      PostgresSourceConfig sourceConfig
- Class org.apache.flink.cdc.connectors.postgres.source.PostgresDialect extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceConfig
      
      PostgresSourceConfig sourceConfig
    - streamFetchTask
      
      PostgresStreamFetchTask streamFetchTask
- Class org.apache.flink.cdc.connectors.postgres.source.PostgresEventDeserializer extends DebeziumEventDeserializationSchema implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - databaseName
      
      String databaseName
    - includeDatabaseInTableId
      
      boolean includeDatabaseInTableId
    - readableMetadataList
      
      List<PostgreSQLReadableMetadata> readableMetadataList
- Class org.apache.flink.cdc.connectors.postgres.source.PostgresSchemaDataTypeInference extends DebeziumSchemaDataTypeInference implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.postgres.source.PostgresSourceBuilder.PostgresIncrementalSource extends JdbcIncrementalSource<T> implements Serializable
- Class org.apache.flink.cdc.connectors.postgres.source.SchemaNameMetadataColumn extends Object implements Serializable
- Class org.apache.flink.cdc.connectors.postgres.source.TableNameMetadataColumn extends Object implements Serializable
Package org.apache.flink.cdc.connectors.postgres.source.config
- Class org.apache.flink.cdc.connectors.postgres.source.config.PostgresSourceConfig extends JdbcSourceConfig implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includeDatabaseInTableId
      
      boolean includeDatabaseInTableId
    - includePartitionedTables
      
      boolean includePartitionedTables
    - logicalMessagePrefixes
      
      List<String> logicalMessagePrefixes
    - lsnCommitCheckpointsDelay
      
      int lsnCommitCheckpointsDelay
    - subtaskId
      
      int subtaskId
- Class org.apache.flink.cdc.connectors.postgres.source.config.PostgresSourceConfigFactory extends JdbcSourceConfigFactory implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - database
      
      String database
    - heartbeatInterval
      
      java.time.Duration heartbeatInterval
    - includeDatabaseInTableId
      
      boolean includeDatabaseInTableId
    - includePartitionedTables
      
      boolean includePartitionedTables
    - logicalMessagePrefixes
      
      List<String> logicalMessagePrefixes
    - lsnCommitCheckpointsDelay
      
      int lsnCommitCheckpointsDelay
    - pluginName
      
      String pluginName
    - schemaList
      
      List<String> schemaList
    - slotName
      
      String slotName
Package org.apache.flink.cdc.connectors.postgres.source.events
- Class org.apache.flink.cdc.connectors.postgres.source.events.OffsetCommitAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.postgres.source.events.OffsetCommitEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - commitOffset
      
      boolean commitOffset
Package org.apache.flink.cdc.connectors.postgres.source.offset
- Class org.apache.flink.cdc.connectors.postgres.source.offset.PostgresOffset extends Offset implements Serializable
- Class org.apache.flink.cdc.connectors.postgres.source.offset.PostgresOffsetFactory extends OffsetFactory implements Serializable
Package org.apache.flink.cdc.connectors.postgres.table
- Class org.apache.flink.cdc.connectors.postgres.table.PostgresValueValidator extends Object implements Serializable
  
  serialVersionUID:
  
  -1870679469578028765L
  - Serialized Fields
    - schemaTable
      
      String schemaTable
Package org.apache.flink.cdc.connectors.sqlserver
- Class org.apache.flink.cdc.connectors.sqlserver.SqlServerValidator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - properties
      
      Properties properties
Package org.apache.flink.cdc.connectors.sqlserver.source
- Class org.apache.flink.cdc.connectors.sqlserver.source.SqlServerEventDeserializer extends DebeziumEventDeserializationSchema implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - includeSchemaChanges
      
      boolean includeSchemaChanges
    - readableMetadataList
      
      List<SqlServerReadableMetadata> readableMetadataList
- Class org.apache.flink.cdc.connectors.sqlserver.source.SqlServerPipelineSource extends SqlServerSourceBuilder.SqlServerIncrementalSource<Event> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.sqlserver.source.SqlServerSchemaDataTypeInference extends DebeziumSchemaDataTypeInference implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.connectors.sqlserver.source.SqlServerSourceBuilder.SqlServerIncrementalSource extends JdbcIncrementalSource<T> implements Serializable
Package org.apache.flink.cdc.connectors.sqlserver.source.config
- Class org.apache.flink.cdc.connectors.sqlserver.source.config.SqlServerSourceConfig extends JdbcSourceConfig implements Serializable
- Class org.apache.flink.cdc.connectors.sqlserver.source.config.SqlServerSourceConfigFactory extends JdbcSourceConfigFactory implements Serializable
Package org.apache.flink.cdc.connectors.sqlserver.source.dialect
- Class org.apache.flink.cdc.connectors.sqlserver.source.dialect.SqlServerDialect extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceConfig
      
      SqlServerSourceConfig sourceConfig
Package org.apache.flink.cdc.connectors.sqlserver.source.offset
- Class org.apache.flink.cdc.connectors.sqlserver.source.offset.LsnFactory extends OffsetFactory implements Serializable
  - Serialized Fields
    - sourceConfig
      
      SqlServerSourceConfig sourceConfig
- Class org.apache.flink.cdc.connectors.sqlserver.source.offset.LsnOffset extends Offset implements Serializable
Package org.apache.flink.cdc.connectors.starrocks.sink
- Class org.apache.flink.cdc.connectors.starrocks.sink.EventRecordSerializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - zoneId
      
      java.time.ZoneId zoneId
      
      The local time zone used when converting from TIMESTAMP WITH LOCAL TIME ZONE.
- Class org.apache.flink.cdc.connectors.starrocks.sink.SchemaChangeConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - timeoutSecond
      
      long timeoutSecond
      
      Timeout for a schema change on StarRocks side.
- Class org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSink extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schemaChangeConfig
      
      SchemaChangeConfig schemaChangeConfig
      
      Configurations for schema change.
    - sinkOptions
      
      com.starrocks.connector.flink.table.sink.StarRocksSinkOptions sinkOptions
      
      Configurations for sink connector.
    - tableCreateConfig
      
      TableCreateConfig tableCreateConfig
      
      Configurations for creating a StarRocks table.
    - zoneId
      
      java.time.ZoneId zoneId
      
      The local time zone used when converting from TIMESTAMP WITH LOCAL TIME ZONE.
- Class org.apache.flink.cdc.connectors.starrocks.sink.StarRocksEnrichedCatalog extends com.starrocks.connector.flink.catalog.StarRocksCatalog implements Serializable
- Class org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - catalog
      
      StarRocksEnrichedCatalog catalog
    - enabledSchemaEvolutionTypes
      
      Set<SchemaChangeEventType> enabledSchemaEvolutionTypes
    - isOpened
      
      boolean isOpened
    - schemaChangeConfig
      
      SchemaChangeConfig schemaChangeConfig
    - tableCreateConfig
      
      TableCreateConfig tableCreateConfig
- Class org.apache.flink.cdc.connectors.starrocks.sink.TableCreateConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - numBuckets
      
      Integer numBuckets
      
      Number of buckets for the table. null if not set.
    - properties
      
      Map<String,String> properties
      
      Properties for the table.
    - unicodeCharMaxBytes
      
      int unicodeCharMaxBytes
      
      Max bytes allocated for each upstream Unicode character during schema mapping.
Package org.apache.flink.cdc.connectors.tidb
- Class org.apache.flink.cdc.connectors.tidb.TiKVRichParallelSourceFunction extends org.apache.flink.streaming.api.functions.source.RichParallelSourceFunction<T> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - changeEventDeserializationSchema
      
      TiKVChangeEventDeserializationSchema<T> changeEventDeserializationSchema
    - database
      
      String database
    - snapshotEventDeserializationSchema
      
      TiKVSnapshotEventDeserializationSchema<T> snapshotEventDeserializationSchema
    - startupMode
      
      StartupMode startupMode
    - tableName
      
      String tableName
    - tiConf
      
      org.tikv.common.TiConfiguration tiConf
Package org.apache.flink.cdc.connectors.tidb.table
- Class org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVChangeEventDeserializationSchema extends RowDataTiKVEventDeserializationSchemaBase implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resultTypeInfo
      
      org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo
      
      TypeInformation of the produced RowData. *
- Class org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVEventDeserializationSchemaBase extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - appendMetadataCollector
      
      TiKVAppendMetadataCollector appendMetadataCollector
      
      A wrapped output collector which is used to append metadata columns after physical columns.
    - database
      
      String database
    - hasMetadata
      
      boolean hasMetadata
      
      Whether the deserializer needs to handle metadata columns.
    - physicalConverter
      
      TiKVDeserializationRuntimeConverter physicalConverter
      
      Runtime converter that converts Tikv Kvrpcpb.KvPairs into RowData consisted of physical column values.
    - tableInfo
      
      org.tikv.common.meta.TiTableInfo tableInfo
      
      Information of the TiKV table. *
    - tableName
      
      String tableName
    - tiConf
      
      org.tikv.common.TiConfiguration tiConf
- Class org.apache.flink.cdc.connectors.tidb.table.RowDataTiKVSnapshotEventDeserializationSchema extends RowDataTiKVEventDeserializationSchemaBase implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - resultTypeInfo
      
      org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo
      
      TypeInformation of the produced RowData. *
- Class org.apache.flink.cdc.connectors.tidb.table.TiKVAppendMetadataCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - metadataConverters
      
      TiKVMetadataConverter[] metadataConverters
Package org.apache.flink.cdc.connectors.tidb.table.utils
- Class org.apache.flink.cdc.connectors.tidb.table.utils.UriHostMapping extends Object implements Serializable
  - Serialized Fields
    - hostMapping
      
      ConcurrentMap<String,String> hostMapping
Package org.apache.flink.cdc.connectors.values
- Class org.apache.flink.cdc.connectors.values.ValuesDatabase.ErrorOnChangeMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - enabledSchemaEvolutionTypes
      
      Set<SchemaChangeEventType> enabledSchemaEvolutionTypes
- Class org.apache.flink.cdc.connectors.values.ValuesDatabase.ValuesMetadataApplier extends Object implements Serializable
  - Serialized Fields
    - enabledSchemaEvolutionTypes
      
      Set<SchemaChangeEventType> enabledSchemaEvolutionTypes
    - materializedInMemory
      
      boolean materializedInMemory
Package org.apache.flink.cdc.connectors.values.sink
- Class org.apache.flink.cdc.connectors.values.sink.ValuesDataSink extends Object implements Serializable
  - Serialized Fields
    - errorOnSchemaChange
      
      boolean errorOnSchemaChange
    - materializedInMemory
      
      boolean materializedInMemory
      
      ValuesDataSinkOptions.MATERIALIZED_IN_MEMORY.
    - print
      
      boolean print
    - sinkApi
      
      ValuesDataSink.SinkApi sinkApi
- Class org.apache.flink.cdc.connectors.values.sink.ValuesDataSinkFunction extends Object implements Serializable
  - Serialized Fields
    - fieldGetterMaps
      
      Map<TableId,List<RecordData.FieldGetter>> fieldGetterMaps
    - materializedInMemory
      
      boolean materializedInMemory
    - print
      
      boolean print
    - schemaMaps
      
      Map<TableId,Schema> schemaMaps
      
      keep the relationship of TableId and Schema as write method may rely on the schema information of DataChangeEvent.
Package org.apache.flink.cdc.connectors.values.source
- Class org.apache.flink.cdc.connectors.values.source.OpTsMetadataColumn extends Object implements Serializable
- Class org.apache.flink.cdc.connectors.values.source.TimestampTypeMetadataColumn extends Object implements Serializable
Package org.apache.flink.cdc.connectors.vitess
- Class org.apache.flink.cdc.connectors.vitess.VitessValidator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - configuration
      
      Map<String,String> configuration
Package org.apache.flink.cdc.debezium
- Class org.apache.flink.cdc.debezium.DebeziumSourceFunction extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<T> implements Serializable
  
  serialVersionUID:
  
  -5808108641062931623L
  - Serialized Fields
    - debeziumStarted
      
      boolean debeziumStarted
      
      Flag indicating whether the Debezium Engine is started.
    - deserializer
      
      DebeziumDeserializationSchema<T> deserializer
      
      The schema to convert from Debezium's messages into Flink's objects.
    - pendingOffsetsToCommit
      
      org.apache.commons.collections.map.LinkedMap pendingOffsetsToCommit
      
      Data for pending but uncommitted offsets.
    - properties
      
      Properties properties
      
      User-supplied properties for Kafka. *
    - specificOffset
      
      DebeziumOffset specificOffset
      
      The specific binlog offset to read from when the first startup.
    - validator
      
      Validator validator
      
      Validator to validate the connected database satisfies the cdc connector's requirements.
- Class org.apache.flink.cdc.debezium.JsonDebeziumDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - customConverterConfigs
      
      Map<String,Object> customConverterConfigs
      
      The custom configurations for JsonConverter.
    - includeSchema
      
      Boolean includeSchema
      
      Configuration whether to enable JsonConverterConfig.SCHEMAS_ENABLE_CONFIG to include schema in messages.
- Class org.apache.flink.cdc.debezium.StringDebeziumDeserializationSchema extends Object implements Serializable
  
  serialVersionUID:
  
  -3168848963265670603L
Package org.apache.flink.cdc.debezium.event
- Class org.apache.flink.cdc.debezium.event.DebeziumEventDeserializationSchema extends SourceRecordEventDeserializer implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - changelogMode
      
      DebeziumChangelogMode changelogMode
      
      Changelog Mode to use for encoding changes in Flink internal data structure.
    - createTableEventCache
      
      Map<io.debezium.relational.TableId,CreateTableEvent> createTableEventCache
    - schemaDataTypeInference
      
      SchemaDataTypeInference schemaDataTypeInference
      
      The schema data type inference.
- Class org.apache.flink.cdc.debezium.event.DebeziumSchemaDataTypeInference extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.debezium.event.SourceRecordEventDeserializer extends Object implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.debezium.internal
- Class org.apache.flink.cdc.debezium.internal.DebeziumOffset extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sourceOffset
      
      Map<String,?> sourceOffset
    - sourcePartition
      
      Map<String,?> sourcePartition
- Class org.apache.flink.cdc.debezium.internal.Handover.ClosedException extends Exception implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.debezium.table
- Class org.apache.flink.cdc.debezium.table.AppendMetadataCollector extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - appendOnly
      
      boolean appendOnly
    - metadataConverters
      
      MetadataConverter[] metadataConverters
- Class org.apache.flink.cdc.debezium.table.RowDataDebeziumDeserializeSchema extends Object implements Serializable
  
  serialVersionUID:
  
  2L
  - Serialized Fields
    - appendMetadataCollector
      
      AppendMetadataCollector appendMetadataCollector
      
      A wrapped output collector which is used to append metadata columns after physical columns.
    - appendOnly
      
      boolean appendOnly
    - changelogMode
      
      DebeziumChangelogMode changelogMode
      
      Changelog Mode to use for encoding changes in Flink internal data structure.
    - hasMetadata
      
      boolean hasMetadata
      
      Whether the deserializer needs to handle metadata columns.
    - physicalConverter
      
      DeserializationRuntimeConverter physicalConverter
      
      Runtime converter that converts Kafka SourceRecords into RowData consisted of physical column values.
    - resultTypeInfo
      
      org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> resultTypeInfo
      
      TypeInformation of the produced RowData. *
    - validator
      
      RowDataDebeziumDeserializeSchema.ValueValidator validator
      
      Validator to validate the row value.
Package org.apache.flink.cdc.models.dummy
- Class org.apache.flink.cdc.models.dummy.DummyModelClient extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - debug
      
      boolean debug
Package org.apache.flink.cdc.models.openai
- Class org.apache.flink.cdc.models.openai.OpenAiCompatibleModelClient extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - apiKey
      
      String apiKey
    - configuredSystemPrompt
      
      String configuredSystemPrompt
    - endpoint
      
      String endpoint
    - model
      
      String model
    - params
      
      org.apache.flink.cdc.models.openai.OpenAiRequestParams params
Package org.apache.flink.cdc.runtime.operators.schema.common.event
- Class org.apache.flink.cdc.runtime.operators.schema.common.event.FlushSuccessEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - sinkSubTaskId
      
      int sinkSubTaskId
      
      The sink subtask finished flushing.
    - sourceSubTaskId
      
      int sourceSubTaskId
      
      The schema changes initiated from which source partition.
- Class org.apache.flink.cdc.runtime.operators.schema.common.event.GetEvolvedSchemaRequest extends Object implements Serializable
  - Serialized Fields
    - schemaVersion
      
      int schemaVersion
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.runtime.operators.schema.common.event.GetEvolvedSchemaResponse extends Object implements Serializable
  - Serialized Fields
    - schema
      
      Schema schema
- Class org.apache.flink.cdc.runtime.operators.schema.common.event.GetOriginalSchemaRequest extends Object implements Serializable
  - Serialized Fields
    - schemaVersion
      
      int schemaVersion
    - tableId
      
      TableId tableId
- Class org.apache.flink.cdc.runtime.operators.schema.common.event.GetOriginalSchemaResponse extends Object implements Serializable
  - Serialized Fields
    - schema
      
      Schema schema
- Class org.apache.flink.cdc.runtime.operators.schema.common.event.SinkWriterRegisterEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - subtask
      
      int subtask
Package org.apache.flink.cdc.runtime.operators.schema.distributed
- Class org.apache.flink.cdc.runtime.operators.schema.distributed.SchemaCoordinatorProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - existingTableSchemaExpansionMode
      
      ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode
    - metadataApplier
      
      MetadataApplier metadataApplier
    - operatorID
      
      org.apache.flink.runtime.jobgraph.OperatorID operatorID
    - operatorName
      
      String operatorName
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - rpcTimeout
      
      java.time.Duration rpcTimeout
    - schemaChangeBehavior
      
      SchemaChangeBehavior schemaChangeBehavior
- Class org.apache.flink.cdc.runtime.operators.schema.distributed.SchemaOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  - Serialized Fields
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - rpcTimeOut
      
      java.time.Duration rpcTimeOut
    - schemaChangeBehavior
      
      SchemaChangeBehavior schemaChangeBehavior
    - timezone
      
      String timezone
- Class org.apache.flink.cdc.runtime.operators.schema.distributed.SchemaOperatorFactory extends org.apache.flink.streaming.api.operators.SimpleOperatorFactory<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - existingTableSchemaExpansionMode
      
      ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode
    - metadataApplier
      
      MetadataApplier metadataApplier
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - rpcTimeout
      
      java.time.Duration rpcTimeout
    - schemaChangeBehavior
      
      SchemaChangeBehavior schemaChangeBehavior
Package org.apache.flink.cdc.runtime.operators.schema.distributed.event
- Class org.apache.flink.cdc.runtime.operators.schema.distributed.event.SchemaChangeRequest extends Object implements Serializable
  - Serialized Fields
    - schemaChangeEvent
      
      SchemaChangeEvent schemaChangeEvent
    - sinkSubTaskId
      
      int sinkSubTaskId
    - sourceSubTaskId
      
      int sourceSubTaskId
- Class org.apache.flink.cdc.runtime.operators.schema.distributed.event.SchemaChangeResponse extends Object implements Serializable
  - Serialized Fields
    - evolvedSchemaChangeEvents
      
      List<SchemaChangeEvent> evolvedSchemaChangeEvents
    - evolvedSchemas
      
      Map<TableId,Schema> evolvedSchemas
Package org.apache.flink.cdc.runtime.operators.schema.regular
- Class org.apache.flink.cdc.runtime.operators.schema.regular.BatchSchemaOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - alreadyMergedCreateTableTables
      
      boolean alreadyMergedCreateTableTables
    - metadataApplier
      
      MetadataApplier metadataApplier
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - timezone
      
      String timezone
- Class org.apache.flink.cdc.runtime.operators.schema.regular.SchemaCoordinatorProvider extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - existingTableSchemaExpansionMode
      
      ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode
    - metadataApplier
      
      MetadataApplier metadataApplier
    - operatorID
      
      org.apache.flink.runtime.jobgraph.OperatorID operatorID
    - operatorName
      
      String operatorName
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - rpcTimeout
      
      java.time.Duration rpcTimeout
    - schemaChangeBehavior
      
      SchemaChangeBehavior schemaChangeBehavior
- Class org.apache.flink.cdc.runtime.operators.schema.regular.SchemaOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - rpcTimeout
      
      java.time.Duration rpcTimeout
    - schemaChangeBehavior
      
      SchemaChangeBehavior schemaChangeBehavior
    - timezone
      
      String timezone
- Class org.apache.flink.cdc.runtime.operators.schema.regular.SchemaOperatorFactory extends org.apache.flink.streaming.api.operators.SimpleOperatorFactory<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - existingTableSchemaExpansionMode
      
      ExistingTableSchemaExpansionMode existingTableSchemaExpansionMode
    - metadataApplier
      
      MetadataApplier metadataApplier
    - routeMode
      
      RouteMode routeMode
    - routingRules
      
      List<RouteRule> routingRules
    - rpcTimeout
      
      java.time.Duration rpcTimeout
    - schemaChangeBehavior
      
      SchemaChangeBehavior schemaChangeBehavior
Package org.apache.flink.cdc.runtime.operators.schema.regular.event
- Class org.apache.flink.cdc.runtime.operators.schema.regular.event.SchemaChangeRequest extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schemaChangeEvent
      
      SchemaChangeEvent schemaChangeEvent
      
      The schema changes.
    - subTaskId
      
      int subTaskId
      
      The ID of subTask that initiated the request.
    - tableId
      
      TableId tableId
      
      The sender of the request.
- Class org.apache.flink.cdc.runtime.operators.schema.regular.event.SchemaChangeResponse extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - appliedSchemaChangeEvents
      
      List<SchemaChangeEvent> appliedSchemaChangeEvents
      
      Actually finished schema change events. This will only be effective if status is accepted.
    - evolvedSchemas
      
      Map<TableId,Schema> evolvedSchemas
Package org.apache.flink.cdc.runtime.operators.sink
- Class org.apache.flink.cdc.runtime.operators.sink.BatchDataSinkFunctionOperator extends org.apache.flink.streaming.api.operators.StreamSink<Event> implements Serializable
- Class org.apache.flink.cdc.runtime.operators.sink.BatchDataSinkWriterOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<CommT>> implements Serializable
  - Serialized Fields
    - copySinkWriter
      
      org.apache.flink.api.connector.sink2.SinkWriter<Event> copySinkWriter
      
      The internal SinkWriter of flinkWriterOperator, obtained it through reflection to deal with FlushEvent.
    - flinkWriterOperator
      
      Object flinkWriterOperator
      
      Operator that actually execute sink logic.
    - mailboxExecutor
      
      org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor
    - processingTimeService
      
      org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService
    - sink
      
      org.apache.flink.api.connector.sink2.Sink<Event> sink
- Class org.apache.flink.cdc.runtime.operators.sink.DataSinkFunctionOperator extends org.apache.flink.streaming.api.operators.StreamSink<Event> implements Serializable
  - Serialized Fields
    - processedTableIds
      
      Set<TableId> processedTableIds
      
      A set of TableId that already processed CreateTableEvent.
    - schemaEvolutionClient
      
      SchemaEvolutionClient schemaEvolutionClient
    - schemaOperatorID
      
      org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID
- Class org.apache.flink.cdc.runtime.operators.sink.DataSinkWriterOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<CommT>> implements Serializable
  - Serialized Fields
    - copySinkWriter
      
      org.apache.flink.api.connector.sink2.SinkWriter<Event> copySinkWriter
      
      The internal SinkWriter of flinkWriterOperator, obtained it through reflection to deal with FlushEvent.
    - flinkWriterOperator
      
      Object flinkWriterOperator
      
      Operator that actually execute sink logic.
    - mailboxExecutor
      
      org.apache.flink.api.common.operators.MailboxExecutor mailboxExecutor
    - processedTableIds
      
      Set<TableId> processedTableIds
      
      A set of TableId that already processed CreateTableEvent.
    - processingTimeService
      
      org.apache.flink.streaming.runtime.tasks.ProcessingTimeService processingTimeService
    - schemaEvolutionClient
      
      SchemaEvolutionClient schemaEvolutionClient
    - schemaOperatorID
      
      org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID
    - sink
      
      org.apache.flink.api.connector.sink2.Sink<Event> sink
- Class org.apache.flink.cdc.runtime.operators.sink.DataSinkWriterOperatorFactory extends org.apache.flink.streaming.api.operators.AbstractStreamOperatorFactory<org.apache.flink.streaming.api.connector.sink2.CommittableMessage<CommT>> implements Serializable
  - Serialized Fields
    - isBounded
      
      boolean isBounded
    - schemaOperatorID
      
      org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorID
    - sink
      
      org.apache.flink.api.connector.sink2.Sink<Event> sink
Package org.apache.flink.cdc.runtime.operators.sink.exception
- Class org.apache.flink.cdc.runtime.operators.sink.exception.SinkWrapperException extends RuntimeException implements Serializable
Package org.apache.flink.cdc.runtime.operators.transform
- Class org.apache.flink.cdc.runtime.operators.transform.PostTransformOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - decimalPrecisionMode
      
      DecimalPrecisionMode decimalPrecisionMode
    - hasAsteriskMap
      
      Map<TableId,Boolean> hasAsteriskMap
    - modelClients
      
      Map<String,AiModelClient> modelClients
    - postTransformInfoMap
      
      Map<TableId,PostTransformChangeInfo> postTransformInfoMap
    - projectedColumnsMap
      
      Map<TableId,List<String>> projectedColumnsMap
    - timezone
      
      String timezone
    - transformRules
      
      List<TransformRule> transformRules
    - udfFunctions
      
      List<org.apache.flink.api.java.tuple.Tuple3<String,String,Map<String,String>>> udfFunctions
- Class org.apache.flink.cdc.runtime.operators.transform.PreTransformOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - preTransformChangeInfoMap
      
      Map<TableId,PreTransformChangeInfo> preTransformChangeInfoMap
    - schemaMetadataTransformers
      
      List<org.apache.flink.api.java.tuple.Tuple2<Selectors,SchemaMetadataTransform>> schemaMetadataTransformers
    - transformRules
      
      List<TransformRule> transformRules
    - udfFunctions
      
      List<org.apache.flink.api.java.tuple.Tuple3<String,String,Map<String,String>>> udfFunctions
- Class org.apache.flink.cdc.runtime.operators.transform.ProjectionColumn extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - column
      
      Column column
    - columnNameMap
      
      Map<String,String> columnNameMap
    - expression
      
      String expression
    - originalColumnNames
      
      List<String> originalColumnNames
    - scriptExpression
      
      String scriptExpression
- Class org.apache.flink.cdc.runtime.operators.transform.SchemaMetadataTransform extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - options
      
      Map<String,String> options
    - partitionKeys
      
      List<String> partitionKeys
    - primaryKeys
      
      List<String> primaryKeys
- Class org.apache.flink.cdc.runtime.operators.transform.TransformExpressionKey extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - argumentClasses
      
      List<Class<?>> argumentClasses
    - argumentNames
      
      List<String> argumentNames
    - columnNameMap
      
      Map<String,String> columnNameMap
    - compiledExpression
      
      String compiledExpression
    - originalExpression
      
      String originalExpression
    - returnClass
      
      Class<?> returnClass
- Class org.apache.flink.cdc.runtime.operators.transform.TransformFilter extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnNameMap
      
      Map<String,String> columnNameMap
    - columnNames
      
      List<String> columnNames
    - expression
      
      String expression
- Class org.apache.flink.cdc.runtime.operators.transform.TransformProjection extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - projection
      
      String projection
    - projectionColumns
      
      List<ProjectionColumn> projectionColumns
- Class org.apache.flink.cdc.runtime.operators.transform.TransformRule extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - filter
      
      String filter
    - partitionKey
      
      String partitionKey
    - postTransformConverter
      
      String postTransformConverter
    - primaryKey
      
      String primaryKey
    - projection
      
      String projection
    - supportedMetadataColumns
      
      SupportedMetadataColumn[] supportedMetadataColumns
    - tableInclusions
      
      String tableInclusions
    - tableOption
      
      String tableOption
    - tableOptionsDelimiter
      
      String tableOptionsDelimiter
- Class org.apache.flink.cdc.runtime.operators.transform.UserDefinedFunctionDescriptor extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - className
      
      String className
    - classpath
      
      String classpath
    - isCdcPipelineUdf
      
      boolean isCdcPipelineUdf
    - name
      
      String name
    - parameters
      
      Map<String,String> parameters
    - returnTypeHint
      
      DataType returnTypeHint
Package org.apache.flink.cdc.runtime.operators.transform.async
- Class org.apache.flink.cdc.runtime.operators.transform.async.AsyncPostTransformFunction extends org.apache.flink.streaming.api.functions.async.RichAsyncFunction<Event,Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - asyncWorkerThreads
      
      int asyncWorkerThreads
    - decimalPrecisionMode
      
      DecimalPrecisionMode decimalPrecisionMode
    - modelClients
      
      Map<String,AiModelClient> modelClients
    - tableInfoMap
      
      Map<TableId,org.apache.flink.cdc.runtime.operators.transform.async.AsyncPostTransformFunction.PostTransformTableInfo> tableInfoMap
    - timezone
      
      String timezone
    - transformRules
      
      List<TransformRule> transformRules
    - udfFunctions
      
      List<org.apache.flink.api.java.tuple.Tuple3<String,String,Map<String,String>>> udfFunctions
- Class org.apache.flink.cdc.runtime.operators.transform.async.AsyncPostTransformOperatorFactory extends org.apache.flink.streaming.api.operators.async.AsyncWaitOperatorFactory<Event,Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - asyncFunction
      
      AsyncPostTransformFunction asyncFunction
    - capacity
      
      int capacity
    - timeout
      
      long timeout
Package org.apache.flink.cdc.runtime.operators.transform.converter
- Class org.apache.flink.cdc.runtime.operators.transform.converter.SoftDeleteConverter extends Object implements Serializable
Package org.apache.flink.cdc.runtime.operators.transform.exceptions
- Class org.apache.flink.cdc.runtime.operators.transform.exceptions.TransformException extends RuntimeException implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.runtime.partitioning
- Class org.apache.flink.cdc.runtime.partitioning.BatchRegularPrePartitionOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<PartitioningEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - downstreamParallelism
      
      int downstreamParallelism
    - hashFunctionProvider
      
      HashFunctionProvider<DataChangeEvent> hashFunctionProvider
- Class org.apache.flink.cdc.runtime.partitioning.DistributedPrePartitionOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<PartitioningEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - downstreamParallelism
      
      int downstreamParallelism
    - hashFunctionProvider
      
      HashFunctionProvider<DataChangeEvent> hashFunctionProvider
- Class org.apache.flink.cdc.runtime.partitioning.EventPartitioner extends Object implements Serializable
- Class org.apache.flink.cdc.runtime.partitioning.PartitioningEventKeySelector extends Object implements Serializable
- Class org.apache.flink.cdc.runtime.partitioning.PostPartitionProcessor extends org.apache.flink.api.common.functions.RichMapFunction<PartitioningEvent,Event> implements Serializable
- Class org.apache.flink.cdc.runtime.partitioning.RegularPrePartitionOperator extends org.apache.flink.cdc.runtime.operators.AbstractStreamOperatorAdapter<PartitioningEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - downstreamParallelism
      
      int downstreamParallelism
    - hashFunctionProvider
      
      HashFunctionProvider<DataChangeEvent> hashFunctionProvider
    - schemaOperatorId
      
      org.apache.flink.runtime.jobgraph.OperatorID schemaOperatorId
Package org.apache.flink.cdc.runtime.serializer
- Class org.apache.flink.cdc.runtime.serializer.BooleanSerializer extends TypeSerializerSingleton<Boolean> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.BytePrimitiveArraySerializer extends TypeSerializerSingleton<byte[]> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.ByteSerializer extends TypeSerializerSingleton<Byte> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.DoubleSerializer extends TypeSerializerSingleton<Double> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.EnumSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<T extends Enum<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialization Methods
    - readObject
      
      private void readObject(ObjectInputStream in) throws IOException, ClassNotFoundException
      
      Throws:
      
      IOException
      
      ClassNotFoundException
  - Serialized Fields
    - enumClass
      
      Class<T extends Enum<T>> enumClass
    - values
      
      T extends Enum<T>[] values
      
      Array of enum constants with their indexes identical to their ordinals in the EnumSerializer.valueToOrdinal map. Serves as a bidirectional map to have fast access from ordinal to value. May be reordered after reconfiguration.
    - valueToOrdinal
      
      Map<T extends Enum<T>,Integer> valueToOrdinal
      
      Maintain our own map of enum value to their ordinal, instead of directly using Enum.ordinal(). This allows us to maintain backwards compatibility for previous serialized data in the case that the order of enum constants was changed or new constants were added.
      On a fresh start with no reconfiguration, the ordinals would simply be identical to the enum constants actual ordinals. Ordinals may change after reconfiguration.
- Class org.apache.flink.cdc.runtime.serializer.FloatSerializer extends TypeSerializerSingleton<Float> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.IntSerializer extends TypeSerializerSingleton<Integer> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.LinkedListSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<LinkedList<T>> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - elementSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer
    - hasNullMask
      
      boolean hasNullMask
- Class org.apache.flink.cdc.runtime.serializer.ListSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<List<T>> implements Serializable
  
  serialVersionUID:
  
  1119562170939152304L
  - Serialized Fields
    - elementSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> elementSerializer
      
      The serializer for the elements of the list.
- Class org.apache.flink.cdc.runtime.serializer.LongSerializer extends TypeSerializerSingleton<Long> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.MapSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<Map<K,V>> implements Serializable
  
  serialVersionUID:
  
  -6885593032367050078L
  - Serialized Fields
    - keySerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer
      
      The serializer for the keys in the map.
    - valueSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<V> valueSerializer
      
      The serializer for the values in the map.
- Class org.apache.flink.cdc.runtime.serializer.NullableSerializerWrapper extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  - Serialized Fields
    - innerSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<T> innerSerializer
- Class org.apache.flink.cdc.runtime.serializer.ShortSerializer extends TypeSerializerSingleton<Short> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.StringSerializer extends TypeSerializerSingleton<String> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.TableIdSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<TableId> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.TypeSerializerSingleton extends org.apache.flink.api.common.typeutils.TypeSerializer<T> implements Serializable
  
  serialVersionUID:
  
  8766687317209282373L
- Class org.apache.flink.cdc.runtime.serializer.VariantSerializer extends org.apache.flink.api.common.typeutils.base.TypeSerializerSingleton<Variant> implements Serializable
Package org.apache.flink.cdc.runtime.serializer.data
- Class org.apache.flink.cdc.runtime.serializer.data.ArrayDataSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<ArrayData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - elementGetter
      
      ArrayData.ElementGetter elementGetter
    - eleSer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<Object> eleSer
    - eleType
      
      DataType eleType
- Class org.apache.flink.cdc.runtime.serializer.data.DateDataSerializer extends TypeSerializerSingleton<DateData> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.data.DecimalDataSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<DecimalData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
    - scale
      
      int scale
- Class org.apache.flink.cdc.runtime.serializer.data.LocalZonedTimestampDataSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<LocalZonedTimestampData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
- Class org.apache.flink.cdc.runtime.serializer.data.MapDataSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<MapData> implements Serializable
  - Serialized Fields
    - keyGetter
      
      ArrayData.ElementGetter keyGetter
    - keySerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer keySerializer
    - keyType
      
      DataType keyType
    - valueGetter
      
      ArrayData.ElementGetter valueGetter
    - valueSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer valueSerializer
    - valueType
      
      DataType valueType
- Class org.apache.flink.cdc.runtime.serializer.data.RecordDataSerializer extends TypeSerializerSingleton<RecordData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - binarySerializer
      
      BinaryRecordDataSerializer binarySerializer
- Class org.apache.flink.cdc.runtime.serializer.data.StringDataSerializer extends TypeSerializerSingleton<StringData> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.data.TimeDataSerializer extends TypeSerializerSingleton<TimeData> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.serializer.data.TimestampDataSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<TimestampData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
- Class org.apache.flink.cdc.runtime.serializer.data.ZonedTimestampDataSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<ZonedTimestampData> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - precision
      
      int precision
    - stringSerializer
      
      StringSerializer stringSerializer
Package org.apache.flink.cdc.runtime.serializer.data.binary
- Class org.apache.flink.cdc.runtime.serializer.data.binary.BinaryRecordDataSerializer extends TypeSerializerSingleton<BinaryRecordData> implements Serializable
  
  serialVersionUID:
  
  1L
Package org.apache.flink.cdc.runtime.serializer.data.writer
Package org.apache.flink.cdc.runtime.serializer.event
- Class org.apache.flink.cdc.runtime.serializer.event.AddColumnEventSerializer extends TypeSerializerSingleton<AddColumnEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnsSerializer
      
      ListSerializer<AddColumnEvent.ColumnWithPosition> columnsSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.AlterColumnTypeEventSerializer extends TypeSerializerSingleton<AlterColumnTypeEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - commentsSerializer
      
      MapSerializer<String,String> commentsSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
    - typeMapSerializer
      
      MapSerializer<String,DataType> typeMapSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.AlterTableCommentEventSerializer extends TypeSerializerSingleton<AlterTableCommentEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - commentSerializer
      
      StringSerializer commentSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.CreateTableEventSerializer extends TypeSerializerSingleton<CreateTableEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - schemaSerializer
      
      SchemaSerializer schemaSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.DataChangeEventSerializer extends TypeSerializerSingleton<DataChangeEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - metaSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<Map<String,String>> metaSerializer
    - opSerializer
      
      EnumSerializer<OperationType> opSerializer
    - recordDataSerializer
      
      RecordDataSerializer recordDataSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.DropColumnEventSerializer extends TypeSerializerSingleton<DropColumnEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnNamesSerializer
      
      ListSerializer<String> columnNamesSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.DropTableEventSerializer extends TypeSerializerSingleton<DropTableEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
    - typeMapSerializer
      
      MapSerializer<String,DataType> typeMapSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.EventSerializer extends TypeSerializerSingleton<Event> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dataChangeEventSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<DataChangeEvent> dataChangeEventSerializer
    - enumSerializer
      
      EnumSerializer<org.apache.flink.cdc.runtime.serializer.event.EventSerializer.EventClass> enumSerializer
    - listSerializer
      
      ListSerializer<TableId> listSerializer
    - schemaChangeEventSerializer
      
      SchemaChangeEventSerializer schemaChangeEventSerializer
    - schemaChangeEventTypeEnumSerializer
      
      EnumSerializer<SchemaChangeEventType> schemaChangeEventTypeEnumSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.PartitioningEventSerializer extends TypeSerializerSingleton<PartitioningEvent> implements Serializable
  - Serialized Fields
    - eventSerializer
      
      EventSerializer eventSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.RenameColumnEventSerializer extends TypeSerializerSingleton<RenameColumnEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - nameMapSerializer
      
      MapSerializer<String,String> nameMapSerializer
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.SchemaChangeEventSerializer extends TypeSerializerSingleton<SchemaChangeEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - enumSerializer
      
      EnumSerializer<SchemaChangeEventType> enumSerializer
- Class org.apache.flink.cdc.runtime.serializer.event.TruncateTableEventSerializer extends TypeSerializerSingleton<TruncateTableEvent> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - tableIdSerializer
      
      TableIdSerializer tableIdSerializer
    - typeMapSerializer
      
      MapSerializer<String,DataType> typeMapSerializer
Package org.apache.flink.cdc.runtime.serializer.schema
- Class org.apache.flink.cdc.runtime.serializer.schema.ColumnSerializer extends TypeSerializerSingleton<Column> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - enumSerializer
      
      EnumSerializer<org.apache.flink.cdc.runtime.serializer.schema.ColumnSerializer.ColumnType> enumSerializer
    - metadataColumnSerializer
      
      MetadataColumnSerializer metadataColumnSerializer
    - physicalColumnSerializer
      
      PhysicalColumnSerializer physicalColumnSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.ColumnWithPositionSerializer extends TypeSerializerSingleton<AddColumnEvent.ColumnWithPosition> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - addColumnSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<Column> addColumnSerializer
    - existedColumnNameSerializer
      
      org.apache.flink.api.common.typeutils.TypeSerializer<String> existedColumnNameSerializer
    - positionEnumSerializer
      
      EnumSerializer<AddColumnEvent.ColumnPosition> positionEnumSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.DataFieldSerializer extends TypeSerializerSingleton<DataField> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dataTypeSerializer
      
      DataTypeSerializer dataTypeSerializer
    - stringSerializer
      
      StringSerializer stringSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.DataTypeSerializer extends org.apache.flink.api.common.typeutils.TypeSerializer<DataType> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - enumSerializer
      
      EnumSerializer<org.apache.flink.cdc.runtime.serializer.schema.DataTypeSerializer.DataTypeClass> enumSerializer
    - rowTypeSerializer
      
      RowTypeSerializer rowTypeSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.MetadataColumnSerializer extends TypeSerializerSingleton<MetadataColumn> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dataTypeSerializer
      
      DataTypeSerializer dataTypeSerializer
    - stringSerializer
      
      StringSerializer stringSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.PhysicalColumnSerializer extends TypeSerializerSingleton<PhysicalColumn> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dataTypeSerializer
      
      DataTypeSerializer dataTypeSerializer
    - stringSerializer
      
      StringSerializer stringSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.RowTypeSerializer extends TypeSerializerSingleton<RowType> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - fieldsSerializer
      
      ListSerializer<DataField> fieldsSerializer
- Class org.apache.flink.cdc.runtime.serializer.schema.SchemaSerializer extends TypeSerializerSingleton<Schema> implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - columnsSerializer
      
      ListSerializer<Column> columnsSerializer
    - optionsSerializer
      
      MapSerializer<String,String> optionsSerializer
    - partitionKeysSerializer
      
      ListSerializer<String> partitionKeysSerializer
    - primaryKeysSerializer
      
      ListSerializer<String> primaryKeysSerializer
    - stringSerializer
      
      StringSerializer stringSerializer
Package org.apache.flink.cdc.runtime.typeutils
- Class org.apache.flink.cdc.runtime.typeutils.EventTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<Event> implements Serializable
  
  serialVersionUID:
  
  1L
- Class org.apache.flink.cdc.runtime.typeutils.PartitioningEventTypeInfo extends org.apache.flink.api.common.typeinfo.TypeInformation<PartitioningEvent> implements Serializable
Package org.apache.flink.udf.examples.java
- Class org.apache.flink.udf.examples.java.AddOneFunctionClass extends org.apache.flink.table.functions.ScalarFunction implements Serializable
- Class org.apache.flink.udf.examples.java.FormatFunctionClass extends org.apache.flink.table.functions.ScalarFunction implements Serializable
- Class org.apache.flink.udf.examples.java.TypeOfFunctionClass extends org.apache.flink.table.functions.ScalarFunction implements Serializable
Package org.tikv.common.util
- Class org.tikv.common.util.Pair extends Object implements Serializable
  - Serialized Fields
    - first
      
      F extends Object first
    - second
      
      S extends Object second
- Class org.tikv.common.util.RangeSplitter.RegionTask extends Object implements Serializable
  - Serialized Fields
    - host
      
      String host
    - ranges
      
      List<org.tikv.kvproto.Coprocessor.KeyRange> ranges
    - region
      
      org.tikv.common.region.TiRegion region
    - store
      
      org.tikv.common.region.TiStore store

Serialized Form

Package com.github.shyiko.mysql.binlog.event.deserialization

Class com.github.shyiko.mysql.binlog.event.deserialization.EventDataDeserializationException extends IOException implements Serializable

Serialized Fields

eventHeader

Class com.github.shyiko.mysql.binlog.event.deserialization.EventDeserializer.EventDataWrapper extends Object implements Serializable

Serialized Fields

external

internal

Class com.github.shyiko.mysql.binlog.event.deserialization.MissingTableMapEventException extends IOException implements Serializable

Package com.oceanbase.connector.flink.sink

Class com.oceanbase.connector.flink.sink.OceanBaseRecordFlusher extends Object implements Serializable

Serialized Fields

connectionProvider

dialect

directLoadCache

lastCheckMemStoreTime

options

tablePartInfoCache

Class com.oceanbase.connector.flink.sink.OceanBaseSink extends Object implements Serializable

Serialized Fields

keyExtractor

options

recordFlusher

recordSerializer

typeSerializer

writerEventListener

Package io.debezium.connector.mysql

Class io.debezium.connector.mysql.EventDataDeserializationExceptionData extends Object implements Serializable

Serialized Fields

cause

Class io.debezium.connector.mysql.StopEventData extends Object implements Serializable

Package io.debezium.embedded

Class io.debezium.embedded.StopConnectorException extends io.debezium.DebeziumException implements Serializable

Package org.apache.calcite.sql.type

Class org.apache.calcite.sql.type.AbstractSqlType extends org.apache.calcite.rel.type.RelDataTypeImpl implements Serializable

Serialized Fields

isNullable

typeName

Class org.apache.calcite.sql.type.ArraySqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

elementType

Class org.apache.calcite.sql.type.BasicSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

collation

precision

scale

typeSystem

wrappedCharset

Class org.apache.calcite.sql.type.IntervalSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

intervalQualifier

typeSystem

Class org.apache.calcite.sql.type.MapSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

keyType

valueType

Class org.apache.calcite.sql.type.MultisetSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

elementType

Class org.apache.calcite.sql.type.ObjectSqlType extends org.apache.calcite.sql.type.AbstractSqlType implements Serializable

Serialized Fields

comparability

family

sqlIdentifier

Package org.apache.doris.flink.sink.batch

Class org.apache.doris.flink.sink.batch.DorisBatchSink extends Object implements Serializable

Serialized Fields

dorisExecutionOptions

dorisOptions

dorisReadOptions

serializer

Class org.apache.doris.flink.sink.batch.DorisBatchStreamLoad extends Object implements Serializable

Serialized Fields

backendUtil

block

bufferMap

bufferMapLock

currentCacheBytes

enableGroupCommit