Presto实战

102

｜

第

7

章

)

WITH

external = true,

column_mapping = 'origin:location:origin,dest:location:dest'

);

7.2.2

　

Accumulo

中的谓词下推

在

Accumulo

连接器中，

Presto

可以利用

Accumulo

内置的二级索引。为了实现这一点，

Accumulo

连接器需要在每个

tablet

服务器上建立一个自定义的服务器端迭代器

。该迭代器

以

JAR

文件的形式分发

，你必须将其复制到每个

tablet

服务器上的

$ACCUMULO_HOME/

lib/ext

目录中。你可以在

Presto

文档中找到具体做法。

Accumulo

中的索引用于查询行

ID

，行

ID

用来读取实际表中的值。让我们来看一个例子。

SELECT flightnum, origin

FROM flights

WHERE flightdate BETWEEN DATE '2019-10-01' AND 2019-11-05'

AND origin = 'BOS';

在没有索引的情况下，

Presto

会从

Accumulo

中读取整个数据集，然后在

Presto

内部进行

过滤。要读取的

Accumulo

范

围被分配给各个工作节点，这里的范围是整个

tablet

的范围。

如果有索引（如表

7-3

中的示例索引）

，处理范围的数量就可以大大减少。

表7-3：航班表上的索引示例

2019-08-10 flightdate_flightdate:2232 []

2019-10-19 flightdate_flightdate:2232 ...