源端为Elasticsearch/云搜索服务
JSON样例
"from-config-values": { "configs": [ { "inputs": [ { "name": "fromJobConfig.index", "value": "cdm" }, { "name": "fromJobConfig.type", "value": "es" }, { "name": "fromJobConfig.columnList", "value": "a1:numeric&s1:string" }, { "name": "fromJobConfig.splitNestedField", "value": "true" }, { "name": "fromJobConfig.queryString", "value": "last_name:Smith" } ], "name": "fromJobConfig" } ] }
参数说明
参数 |
是否必选 |
类型 |
说明 |
---|---|---|---|
fromJobConfig.index |
是 |
String |
抽取数据的索引,类似关系数据库中的数据库名称。 |
fromJobConfig.type |
是 |
String |
抽取数据的类型,类似关系数据库中的表名。 |
fromJobConfig.columnList |
否 |
String |
需要抽取的字段列表,字段名之间使用“&”分隔,例如:“id&gid&name”。 |
fromJobConfig.splitNestedField |
否 |
Boolean |
选择是否将nested字段的json内容拆分,例如:将“a:{ b:{ c:1, d:{ e:2, f:3 } } }” 拆成三个字段“a.b.c”、“a.b.d.e”、“a.b.d.f”。 |
fromJobConfig.queryString |
否 |
String |
使用Elasticsearch的查询字符串(query string)对源数据进行过滤,CDM只迁移满足过滤条件的数据。 |