alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7640 Get row count if snapshot ordering required

Browse Source
This commit is contained in:
Jiri Pechanec 2024-06-12 06:34:31 +02:00
parent 657492d323
commit b02fa04f1d
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-connector-binlog/src/main/java/io/debezium/connector/binlog/BinlogSnapshotChangeEventSource.java
View File

@ -48,6 +48,7 @@
import io.debezium.pipeline.notification.NotificationService;
import io.debezium.pipeline.source.SnapshottingTask;
import io.debezium.pipeline.source.spi.SnapshotChangeEventSource;
import io.debezium.relational.RelationalDatabaseConnectorConfig.SnapshotTablesRowCountOrder;
import io.debezium.relational.RelationalSnapshotChangeEventSource;
import io.debezium.relational.RelationalTableFilters;
import io.debezium.relational.Table;
@ -548,7 +549,7 @@ protected OptionalLong rowCountForTable(TableId tableId) {
if (getSnapshotSelectOverridesByTable(tableId, connectorConfig.getSnapshotSelectOverridesByTable()) != null) {
return super.rowCountForTable(tableId);
}
if (ROW_ESTIMATE_LOGGER.isInfoEnabled()) {
if (ROW_ESTIMATE_LOGGER.isInfoEnabled() || connectorConfig.snapshotOrderByRowCount() != SnapshotTablesRowCountOrder.DISABLED) {
OptionalLong rowCount = connection.getEstimatedTableSize(tableId);
LOGGER.info("Estimated row count for table {} is {}", tableId, rowCount);
return rowCount;