JNSimba commented on code in PR #371:
URL:
https://github.com/apache/doris-flink-connector/pull/371#discussion_r1577964184
##########
flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java:
##########
@@ -407,37 +406,71 @@ public static Map<String, Integer> getTableBuckets(String
tableBuckets) {
*
* @param tableBucketsMap The table name and buckets map. The key is table
name, the value is
* buckets.
- * @param dorisSchema @{TableSchema}
* @param dorisTable the table name need to set buckets
- * @param tableHasSet The buckets table is set
+ * @param tablesWithBucketsAssigned The buckets table is set
*/
- public void setTableSchemaBuckets(
+ public Integer getTableBuckets(
Map<String, Integer> tableBucketsMap,
- TableSchema dorisSchema,
String dorisTable,
- Set<String> tableHasSet) {
+ Set<String> tablesWithBucketsAssigned) {
- if (tableBucketsMap != null) {
Review Comment:
What are the changes here mainly intended to solve?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
