用于支持DataFlow 从 ElasticSearch 搜索引擎加载数据。

<source type="elasticsearch"
        table_name="cust_id_agmt_id_t"
        source_table_name="test_collection/1"
        columns_mapping="commodity_id,commodity_name,picture_url,price"
        nodes="localhost"
        query='{"match":{ "commodity_id": "12"}}'
        port="9200">
</source>

字段说明：

1. Source_table_name/index_name: 为 ElasticSearch 内部索引名称；
2. Columns_mapping: 为字段映射，格式为 name:type，如果不指定type则为string类型；
3. Nodes：是一个或多个elasticsearch 的节点地址；
4. Port： 是 elasticsearch 的服务端口号，默认：9200；
5. Query: 是一个 elasticsearch query dsl，query 内部的格式， 以 {} 环绕；同时也支持base64:开头的base64(queryDsl)的绑定方式。