Presto实战

高级连接器实例

｜

113

这个逻辑查询计划类似于图

7-5

。可以看到这个计划包括扫描

flights_orc

表和

airport

表。这两个输入都被送入

Join

算子中。但在将机场数据送入

Join

算子之前，我们会应用

一个

Filter

算子，因为我们只想查看

Alaska

机场的结果。在

Join

之后，应用了聚合和分

组操作。最后由

TopN

算子将

ORDER BY

和

LIMIT

一并完成。

图 7-5：联邦查询的逻辑查询计划

为了从

PostgreSQL

中检索数据，

Presto

通过

JDBC

发送一个查询。例如，最原始的方法是

将下面的查询发送到

PostgreSQL

：

SELECT * FROM airline.airport;

然而，

Presto

比这更聪明，

Presto

优化器会试图减少系统间传输的数据量。在这个例子中，

Presto

只从

PostgreSQL

表中查

询它所需要的列，同时将谓词下推到发送至

PostgreSQL

的

SQL

中。

因此，现在从

Presto

发送到

PostgreSQL

的查询会将更多的处理推送到

PostgreSQL

：

SELECT code, city, name FROM airline.airport WHERE state = 'AK';

当到

PostgreSQL

的

JDBC

连接器返回数据到

Presto

时，

Presto

会继续处理在

Presto

查询引

擎中执行的部分。

一些比较简单的查询，如

SELECT * FROM public.airport

，会完全下推到底层数据源中，

如图

7-6

所示，这样查询的执行就发生在

Presto ...