按特定条件批量更新数据,不支持vector、sparse_vector、text 类型字段的更新
参数名 | 类型 | 必须 | 说明 | 子字段 | 类型 | 必选 | 说明 |
---|---|---|---|---|---|---|---|
taskType | string | 是 | 任务类型,填入 filter_update | ||||
taskParams | map | 是 | 任务参数 | collection_name | string | 是 | Collection 名称,必填 |
filter_conds | map | 是 | 过滤条件,支持 must 、must_nor、range、range_out 算子,使用参考标量过滤
| ||||
update_fileds | map | 是 | 需要更新的字段值,必须是标量字段,不支持vector、sparse_vector、text 类型字段的更新
|
import java.util.ArrayList; import java.util.HashMap; import java.util.IdentityHashMap; import java.util.List; import java.util.Random; import org.apache.http.HttpHost; import java.util.Map; import com.volcengine.service.vikingDB.Collection; import com.volcengine.service.vikingDB.Index; import com.volcengine.service.vikingDB.VikingDBService; import com.volcengine.service.vikingDB.common.*; public class test { public static void main(String[] args) throws Exception { VikingDBService vikingDBService = new VikingDBService("", "", "", "",""); HashMap<String, Object> taskParams = new HashMap<>(); List<Map<String, Object>> conditionsList = new ArrayList<>(); Map<String, Object> condition1 = new HashMap<>(); condition1.put("op", "must"); condition1.put("field", "city"); condition1.put("conds", Arrays.asList("beijing")); conditionsList.add(condition1); Map<String, Object> condition2 = new HashMap<>(); condition2.put("op", "range"); condition2.put("field", "user_id"); condition2.put("gt", 0); condition2.put("lt", 4); conditionsList.add(condition2); taskParams.put("filter_conds", conditionsList); taskParams.put("collection_name", "example"); CreateTaskParam taskParam = new CreateTaskParam() .setTaskType(TaskType.FilterUpdate) .setTaskParams(taskParams) .build(); String task_id = vikingDBService.createTask(taskParam); } }
属性 | 说明 |
---|---|
task_id | uuid |