Elasticsearch
-
StarRocks Elasticsearch 外表查询源码解析
这篇文章从源码角度梳理了 StarRocks 查询 Elasticsearch 外表的整体流程。正文先补充 index、mapping、doc_values、`_source`、text 和 keyword 等 ES 基础概念,再说明创建外表后 FE 如何通过 `EsRepository`、`EsMetaStateTracker` 定期同步版本、mapping 和 shard 元信息,并指出 shard 地址选择上的一个已知问题;后半部分继续分析 FE 侧 `EsScanNode` 如何决定 doc_values 下推与分片分配,以及 BE 侧 `ESDataSource`、`ESScanReader`、`ScrollParser` 如何生成 Query DSL、执行 scroll 读取并把返回结果填充到 chunk 中。