| Package | Description |
|---|---|
| com.ververica.cdc.connectors.mysql.source.assigners | |
| com.ververica.cdc.connectors.mysql.source.enumerator |
| Modifier and Type | Class and Description |
|---|---|
class |
MySqlBinlogSplitAssigner
A
MySqlSplitAssigner which only read binlog from current binlog position. |
class |
MySqlHybridSplitAssigner
A
MySqlSplitAssigner that splits tables into small chunk splits based on primary key
range and chunk size and also continue with a binlog split. |
class |
MySqlSnapshotSplitAssigner
A
MySqlSplitAssigner that splits tables into small chunk splits based on primary key
range and chunk size. |
| Constructor and Description |
|---|
MySqlSourceEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<MySqlSplit> context,
MySqlSourceConfig sourceConfig,
MySqlSplitAssigner splitAssigner) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.