Serialized Form (flink-connector-mysql-cdc 2.2.1 API)

Package com.ververica.cdc.connectors.mysql
- Class com.ververica.cdc.connectors.mysql.MySqlValidator extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - dbzProperties
```
Properties dbzProperties
```
    - sourceConfig
```
MySqlSourceConfig sourceConfig
```
- Class com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter extends Object implements Serializable
  
  serialVersionUID:
  
  -4450118969976653497L
  - Serialized Fields
    - startupTimestampMillis
```
long startupTimestampMillis
```
    - serializer
```
com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> serializer
```
Package com.ververica.cdc.connectors.mysql.source
- Class com.ververica.cdc.connectors.mysql.source.MySqlSource extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - configFactory
```
MySqlSourceConfigFactory configFactory
```
    - deserializationSchema
```
com.ververica.cdc.debezium.DebeziumDeserializationSchema<T> deserializationSchema
```
Package com.ververica.cdc.connectors.mysql.source.config
- Class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - hostname
```
String hostname
```
    - port
```
int port
```
    - username
```
String username
```
    - password
```
String password
```
    - databaseList
```
List<E> databaseList
```
    - tableList
```
List<E> tableList
```
    - serverIdRange
```
ServerIdRange serverIdRange
```
    - startupOptions
```
StartupOptions startupOptions
```
    - splitSize
```
int splitSize
```
    - splitMetaGroupSize
```
int splitMetaGroupSize
```
    - fetchSize
```
int fetchSize
```
    - serverTimeZone
```
String serverTimeZone
```
    - connectTimeout
```
java.time.Duration connectTimeout
```
    - connectMaxRetries
```
int connectMaxRetries
```
    - connectionPoolSize
```
int connectionPoolSize
```
    - distributionFactorUpper
```
double distributionFactorUpper
```
    - distributionFactorLower
```
double distributionFactorLower
```
    - includeSchemaChanges
```
boolean includeSchemaChanges
```
    - scanNewlyAddedTableEnabled
```
boolean scanNewlyAddedTableEnabled
```
    - jdbcProperties
```
Properties jdbcProperties
```
    - dbzProperties
```
Properties dbzProperties
```
    - dbzConfiguration
```
io.debezium.config.Configuration dbzConfiguration
```
    - dbzMySqlConfig
```
io.debezium.connector.mysql.MySqlConnectorConfig dbzMySqlConfig
```
- Class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - port
```
int port
```
    - hostname
```
String hostname
```
    - username
```
String username
```
    - password
```
String password
```
    - serverIdRange
```
ServerIdRange serverIdRange
```
    - databaseList
```
List<E> databaseList
```
    - tableList
```
List<E> tableList
```
    - serverTimeZone
```
String serverTimeZone
```
    - startupOptions
```
StartupOptions startupOptions
```
    - splitSize
```
int splitSize
```
    - splitMetaGroupSize
```
int splitMetaGroupSize
```
    - fetchSize
```
int fetchSize
```
    - connectTimeout
```
java.time.Duration connectTimeout
```
    - connectMaxRetries
```
int connectMaxRetries
```
    - connectionPoolSize
```
int connectionPoolSize
```
    - distributionFactorUpper
```
double distributionFactorUpper
```
    - distributionFactorLower
```
double distributionFactorLower
```
    - includeSchemaChanges
```
boolean includeSchemaChanges
```
    - scanNewlyAddedTableEnabled
```
boolean scanNewlyAddedTableEnabled
```
    - jdbcProperties
```
Properties jdbcProperties
```
    - heartbeatInterval
```
java.time.Duration heartbeatInterval
```
    - dbzProperties
```
Properties dbzProperties
```
- Class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - startServerId
```
int startServerId
```
      Start of the range (inclusive).
    - endServerId
```
int endServerId
```
      End of the range (inclusive).
Package com.ververica.cdc.connectors.mysql.source.connection
- Class com.ververica.cdc.connectors.mysql.source.connection.ConnectionPoolId extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - host
```
String host
```
    - port
```
int port
```
Package com.ververica.cdc.connectors.mysql.source.events
- Class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - splitId
```
String splitId
```
    - metaGroupId
```
int metaGroupId
```
      The meta data of binlog split is divided to multiple groups.
    - metaGroup
```
List<E> metaGroup
```
      The serialized meta data of binlog split, it's serialized/deserialize by FinishedSnapshotSplitInfo.serialize(FinishedSnapshotSplitInfo) and FinishedSnapshotSplitInfo.deserialize(byte[]).
- Class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - splitId
```
String splitId
```
    - requestMetaGroupId
```
int requestMetaGroupId
```
- Class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - finishedSplits
```
List<E> finishedSplits
```
- Class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsReportEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - finishedOffsets
```
Map<K,V> finishedOffsets
```
- Class com.ververica.cdc.connectors.mysql.source.events.FinishedSnapshotSplitsRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class com.ververica.cdc.connectors.mysql.source.events.LatestFinishedSplitsSizeEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - latestFinishedSplitsSize
```
int latestFinishedSplitsSize
```
- Class com.ververica.cdc.connectors.mysql.source.events.LatestFinishedSplitsSizeRequestEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class com.ververica.cdc.connectors.mysql.source.events.SuspendBinlogReaderAckEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class com.ververica.cdc.connectors.mysql.source.events.SuspendBinlogReaderEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
- Class com.ververica.cdc.connectors.mysql.source.events.WakeupReaderEvent extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - target
```
WakeupReaderEvent.WakeUpTarget target
```
Package com.ververica.cdc.connectors.mysql.source.offset
- Class com.ververica.cdc.connectors.mysql.source.offset.BinlogOffset extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - offset
```
Map<K,V> offset
```
Package com.ververica.cdc.connectors.mysql.table
- Class com.ververica.cdc.connectors.mysql.table.StartupOptions extends Object implements Serializable
  
  serialVersionUID:
  
  1L
  - Serialized Fields
    - startupMode
```
StartupMode startupMode
```
    - specificOffsetFile
```
String specificOffsetFile
```
    - specificOffsetPos
```
Integer specificOffsetPos
```
    - startupTimestampMillis
```
Long startupTimestampMillis
```

Serialized Form

Package com.ververica.cdc.connectors.mysql

Class com.ververica.cdc.connectors.mysql.MySqlValidator extends Object implements Serializable

Serialized Fields

dbzProperties

sourceConfig

Class com.ververica.cdc.connectors.mysql.SeekBinlogToTimestampFilter extends Object implements Serializable

Serialized Fields

startupTimestampMillis

serializer

Package com.ververica.cdc.connectors.mysql.source

Class com.ververica.cdc.connectors.mysql.source.MySqlSource extends Object implements Serializable

Serialized Fields

configFactory

deserializationSchema

Package com.ververica.cdc.connectors.mysql.source.config

Class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfig extends Object implements Serializable

Serialized Fields

hostname

port

username

password

databaseList

tableList

serverIdRange

startupOptions

splitSize

splitMetaGroupSize

fetchSize

serverTimeZone

connectTimeout

connectMaxRetries

connectionPoolSize

distributionFactorUpper

distributionFactorLower

includeSchemaChanges

scanNewlyAddedTableEnabled

jdbcProperties

dbzProperties

dbzConfiguration

dbzMySqlConfig

Class com.ververica.cdc.connectors.mysql.source.config.MySqlSourceConfigFactory extends Object implements Serializable

Serialized Fields

port

hostname

username

password

serverIdRange

databaseList

tableList

serverTimeZone

startupOptions

splitSize

splitMetaGroupSize

fetchSize

connectTimeout

connectMaxRetries

connectionPoolSize

distributionFactorUpper

distributionFactorLower

includeSchemaChanges

scanNewlyAddedTableEnabled

jdbcProperties

heartbeatInterval

dbzProperties

Class com.ververica.cdc.connectors.mysql.source.config.ServerIdRange extends Object implements Serializable

Serialized Fields

startServerId

endServerId

Package com.ververica.cdc.connectors.mysql.source.connection

Class com.ververica.cdc.connectors.mysql.source.connection.ConnectionPoolId extends Object implements Serializable

Serialized Fields

host

port

Package com.ververica.cdc.connectors.mysql.source.events

Class com.ververica.cdc.connectors.mysql.source.events.BinlogSplitMetaEvent extends Object implements Serializable

Serialized Fields

splitId

metaGroupId

metaGroup