Presto实战

104

｜

第

7

章

在

Cassandra

中处理数据的典型方法是使用为

Cassandra

设计的自定义查询语言：

Cassandra

查询语句

（

Cassandra

QueryLanguage

，

CQL

）。虽然

CQL

从表面上看很像

SQL

，

但它实际上缺少

SQL

的许多有用功能

，如

Join

。总的来说，它和

SQL

相当不同，无法直接

使用依赖

SQL

的标准工具。

然而，借助

Cassandra

连接器

，你可以对

Cassandra

中的数据进行

SQL

查询。最小配置就

是一个简单的

catalog

文件

，比如

etc/catalog/sitedata.properties

。这里的

Cassandra

集群记录

了一个网站上所有的用户交互，例如：

connector.name=cassandra

cassandra.contact-points=sitedata.example.com

有了这个简单的配置，用户就可以查询

Cassandra

中的数据。

Cassandra

中的任何键空间

（例如

cart

）都会在

Presto

中作为一个

schema

暴露出来，现在可以用普通的

SQL

查询表

了，比如

users

：

SELECT * FROM sitedata.cart.users;

该连接器支持许多配置属性，可以让你配置调整

Cassandra

集群的

catalog

，以及启用认证

和连接的

TLS

等。

7.4

　流式系统连接器示例

：

Kafka

流式系统和发布

–

订阅（

pub/sub

）系统旨在处理实时数据源。例如，

LinkedIn

创造的

Apache Kafka

便

是一个高吞吐量、低时延的平台 ...