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

Class MySqlSchemalessSnapshotSplit

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplit

org.apache.flink.cdc.connectors.mysql.source.split.MySqlSnapshotSplit

org.apache.flink.cdc.connectors.mysql.source.split.MySqlSchemalessSnapshotSplit

All Implemented Interfaces:

org.apache.flink.api.connector.source.SourceSplit

public class MySqlSchemalessSnapshotSplit
extends MySqlSnapshotSplit

A kind of MySqlSnapshotSplit without table schema information, it is useful to reduce memory usage in JobManager.

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplit

splitId

Constructor Summary

Constructors

Constructor	Description
MySqlSchemalessSnapshotSplit(io.debezium.relational.TableId tableId, String splitId, org.apache.flink.table.types.logical.RowType splitKeyType, Object[] splitStart, Object[] splitEnd, BinlogOffset highWatermark)

Method Summary

Modifier and Type	Method	Description
MySqlSnapshotSplit	toMySqlSnapshotSplit(io.debezium.relational.history.TableChanges.TableChange tableSchema)	Converts current MySqlSchemalessSnapshotSplit to MySqlSnapshotSplit with given table schema information.

Methods inherited from class org.apache.flink.cdc.connectors.mysql.source.split.MySqlSnapshotSplit

equals, extractChunkId, extractTableId, generateSplitId, getHighWatermark, getSplitEnd, getSplitKeyType, getSplitStart, getTableId, getTableSchemas, hashCode, isSnapshotReadFinished, toSchemalessSnapshotSplit, toString

Methods inherited from class org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplit

asBinlogSplit, asSnapshotSplit, isBinlogSplit, isSnapshotSplit, splitId

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

MySqlSchemalessSnapshotSplit

public MySqlSchemalessSnapshotSplit(io.debezium.relational.TableId tableId,
                                    String splitId,
                                    org.apache.flink.table.types.logical.RowType splitKeyType,
                                    Object[] splitStart,
                                    Object[] splitEnd,
                                    BinlogOffset highWatermark)

Method Detail

toMySqlSnapshotSplit

public final MySqlSnapshotSplit toMySqlSnapshotSplit(io.debezium.relational.history.TableChanges.TableChange tableSchema)

Converts current MySqlSchemalessSnapshotSplit to MySqlSnapshotSplit with given table schema information.