DBZ-2683 Support partition tables。
This commit is contained in:
parent
384010c273
commit
fda628120b
@ -129,6 +129,6 @@ private static String buildTableInPredicate(List<String> tables) {
|
||||
|
||||
StringJoiner tableNames = new StringJoiner(",");
|
||||
tables.forEach(table -> tableNames.add("'" + table + "'"));
|
||||
return " AND table_name IN (" + tableNames + ") AND SEG_NAME IN (" + tableNames + ") ";
|
||||
return " AND table_name IN (" + tableNames + ") ";
|
||||
}
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user