MySqlSplit (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplit

All Implemented Interfaces:

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

Direct Known Subclasses:

MySqlBinlogSplit, MySqlSnapshotSplit
```
public abstract class MySqlSplit
extends Object
implements org.apache.flink.api.connector.source.SourceSplit
```
The split of table comes from a Table that splits by primary key.

Field Summary

Fields
Modifier and Type Field Description

protected String splitId

Constructor Summary

Constructors
Constructor Description

MySqlSplit(String splitId)

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`MySqlBinlogSplit`	`asBinlogSplit()`	Casts this split into a `MySqlBinlogSplit`.
`MySqlSnapshotSplit`	`asSnapshotSplit()`	Casts this split into a `MySqlSnapshotSplit`.
`boolean`	`equals(Object o)`
`abstract Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>`	`getTableSchemas()`
`int`	`hashCode()`
`boolean`	`isBinlogSplit()`	Checks whether this split is a binlog split.
`boolean`	`isSnapshotSplit()`	Checks whether this split is a snapshot split.
`String`	`splitId()`

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail
- splitId
```
protected final String splitId
```

Constructor Detail
- MySqlSplit
```
public MySqlSplit(String splitId)
```

Method Detail
- isSnapshotSplit
```
public final boolean isSnapshotSplit()
```
  Checks whether this split is a snapshot split.
- isBinlogSplit
```
public final boolean isBinlogSplit()
```
  Checks whether this split is a binlog split.
- asSnapshotSplit
```
public final MySqlSnapshotSplit asSnapshotSplit()
```
  Casts this split into a MySqlSnapshotSplit.
- asBinlogSplit
```
public final MySqlBinlogSplit asBinlogSplit()
```
  Casts this split into a MySqlBinlogSplit.
- splitId
```
public String splitId()
```
  Specified by:
  
  splitId in interface org.apache.flink.api.connector.source.SourceSplit
- getTableSchemas
```
public abstract Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> getTableSchemas()
```
- equals
```
public boolean equals(Object o)
```
  Overrides:
  
  equals in class Object
- hashCode
```
public int hashCode()
```
  Overrides:
  
  hashCode in class Object