feat: starrocsk plugin add table config (#8287)

Author: long2ice

backend/plugins/starrocks/tasks/task_data.go

@@ -20,6 +20,7 @@ package tasks
 type TableConfig struct {
 	IncludedColumns []string `mapstructure:"included_columns"`
 	ExcludedColumns []string `mapstructure:"excluded_columns"`
+	Where           string   `mapstructure:"where"`
 }
 
 type StarRocksConfig struct {

backend/plugins/starrocks/tasks/tasks.go

@@ -269,20 +269,26 @@ func copyDataToDst(dc *DataConfigParams, columnMap map[string]string, orderBy st
 	table := dc.SrcTableName
 	starrocksTable := dc.DestTableName
 	starrocksTmpTable := fmt.Sprintf("%s_tmp", starrocksTable)
-
+	tableConfig, ok := config.TableConfigs[table]
+	where := ""
+	if ok {
+		where = tableConfig.Where
+	}
 	var offset int
 	var err error
 	var rows dal.Rows
 	rows, err = db.Cursor(
 		dal.From(table),
 		dal.Orderby(orderBy),
+		dal.Where(where),
 	)
 	if err != nil {
 		if strings.Contains(err.Error(), "cached plan must not change result type") {
 			logger.Warn(err, "skip err: cached plan must not change result type")
 			rows, err = db.Cursor(
 				dal.From(table),
 				dal.Orderby(orderBy),
+				dal.Where(where),
 			)
 			if err != nil {
 				return err