如何在Apache Drill中为Mongo Storage插件实现内部联接的优化（下推？）>

Question

我想扩展Apache Drill Mongo Storage Plugin以按下INNER JOINs。因此，我想将INNER JOIN重写为mongo聚合管道。

我们如何开始在Apache Drill中执行重写。

这里是一个SQL示例：

SELECT *
FROM `mymongo.db`.`test` `test`
  INNER JOIN `mymongo.db`.`test2` `test2`
  ON (`test`.`id` = `test2`.`fk`)
WHERE `test2`.`date` = '09.05.2017'
我在Mongo存储插件中找到了push down子句的WHERE。但是我仍然在为INNER JOINS做同样的事情。 public class MongoPushDownInnerJoinScan extends StoragePluginOptimizerRule的构造如何？我必须实现哪个等效的MongoGroupScan（AbstractGroupScan）？任何帮助将不胜感激。

我想扩展Apache Drill Mongo存储插件以压低INNER JOIN。因此，我想将INNER JOIN重写为mongo聚合管道。我们需要如何开始...

Answer 1

如果要使用类似于SQL的聚合框架进行内部联接，则可以在管道阶段$ lookup进行。

AbstractGroupScan