|
|
|
@ -23,26 +23,26 @@ import com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReader;
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
* The {@link SourceEvent} that {@link MySqlSourceEnumerator} sends to {@link MySqlSourceReader} to
|
|
|
|
|
* pass the latest finished snapshot splits size.
|
|
|
|
|
* pass the latest finished snapshot splits number.
|
|
|
|
|
*/
|
|
|
|
|
public class LatestFinishedSplitsSizeEvent implements SourceEvent {
|
|
|
|
|
public class LatestFinishedSplitsNumberEvent implements SourceEvent {
|
|
|
|
|
|
|
|
|
|
private static final long serialVersionUID = 1L;
|
|
|
|
|
private final int latestFinishedSplitsSize;
|
|
|
|
|
private final int latestFinishedSplitsNumber;
|
|
|
|
|
|
|
|
|
|
public LatestFinishedSplitsSizeEvent(int latestFinishedSplitsSize) {
|
|
|
|
|
this.latestFinishedSplitsSize = latestFinishedSplitsSize;
|
|
|
|
|
public LatestFinishedSplitsNumberEvent(int latestFinishedSplitsNumber) {
|
|
|
|
|
this.latestFinishedSplitsNumber = latestFinishedSplitsNumber;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
public int getLatestFinishedSplitsSize() {
|
|
|
|
|
return latestFinishedSplitsSize;
|
|
|
|
|
public int getLatestFinishedSplitsNumber() {
|
|
|
|
|
return latestFinishedSplitsNumber;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
|
public String toString() {
|
|
|
|
|
return "LatestFinishedSplitsSizeEvent{"
|
|
|
|
|
+ "latestFinishedSplitsSize="
|
|
|
|
|
+ latestFinishedSplitsSize
|
|
|
|
|
return "LatestFinishedSplitsNumberEvent{"
|
|
|
|
|
+ "latestFinishedSplitsNumber="
|
|
|
|
|
+ latestFinishedSplitsNumber
|
|
|
|
|
+ '}';
|
|
|
|
|
}
|
|
|
|
|
}
|