小编Den*_*fel的帖子

我想扩展Apache Drill Mongo存储插件来推送INNER JOIN.因此我想重写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'

我已经找到了倒推的WHERE在蒙戈存储插件条款.但我仍然在努力做同样的事情INNER JOINS.构造器public class MongoPushDownInnerJoinScan extends StoragePluginOptimizerRule看起来怎么样？我必须实现哪个MongoGroupScan(AbstractGroupScan)的等价物？任何帮助将非常感谢.