数据中心连接器

数据中心连接器允许查询远程openLooKeng数据中心。可实现来自本地openLooKeng环境的不同openLooKeng集群之间的数据融合分析。

本端连接器配置

配置数据中心连接器时，在etc/catalog中创建一个属性文件，例如<dc-name>.properties，即将数据中心连接器挂载到<dc-name> 目录。使用以下内容创建配置文件，并根据实际的远端openLooKeng替换connection属性：

基本配置

connector.name=dc
connection-url=http://example.net:8080
connection-user=<远端openLooKeng用户名>
connection-password=<远端openLooKeng密码>

安全配置

当远端openLooKeng开启了安全认证或TLS/SSL通道加密时，则需要在<dc-name>.properties进行相应的安全配置。

Kerberos认证方式

令牌认证方式

外部证书认证方式

SSL/TLS

代理配置

性能优化配置

其他配置

远端openLooKeng配置

远端openLooKeng配置

可以在etc/config.properties中设置以下属性：

远端Nginx配置

在远端开启HA，同时使用Nginx作为代理时，需要对Nginx的配置进行一定修改：

http {
    upstream for_aa {
        ip_hash;
        server 192.168.0.101:8090;   #coordinator-1 的IP和PORT；
        server 192.168.0.102:8090;   #coordinator-2 的IP和PORT；
        check interval=3000 rise=2 fall=5 timeout=1000 type=http;
    }
    upstream for_cross_region {
        hash $hashKey consistent;
        server 192.168.0.101:8090;   #coordinator-1 的IP和PORT；
        server 192.168.0.102:8090;   #coordinator-2 的IP和PORT；
        check interval=3000 rise=2 fall=5 timeout=1000 type=http;
    }
    server {
        listen nginx_ip:8888;
        location / {
            proxy_pass http://for_aa;
            proxy_redirect off;
            proxy_set_header Host $host:$server_port;
        }
        location ^~/v1/dc/(.*)/(.*) {
            set $hashKey $2;
            proxy_redirect off;
            proxy_pass http://for_cross_region;
            proxy_set_header Host $host:$server_port;
        }
        location ^~/v1/dc/statement/(.*)/(.*)/(.*) {
            set $hashKey $3;
            proxy_redirect off;
            proxy_pass http://for_cross_region;
            proxy_set_header Host $host:$server_port;
        }
    }
}

多openLooKeng集群

可以根据需要创建任意多的目录，因此，如果有额外的数据中心，只需添加另一个不同的名称的属性文件到etc/catalog中（确保它以.properties结尾）。例如，如果将属性文件命名为sales.properties，openLooKeng将使用配置的连接器创建一个名为sales的目录。

使用跨域动态过滤

启用跨域动态过滤，在执行跨openLooKeng查询时，在本端生成过滤器，并将过滤器发送到远端openLooKeng进行数据过滤，减少从远端openLooKeng拉取的数据量。需要先确保openLooKeng环境中有启用state-store（相关配置可参考state-store的配置文档）。启用跨域动态过滤有两种方式：

方式一： 可以在etc/config.properties中设置以下属性：

方式二：通过设置session：

例1（通过CLI链接openLooKeng）：

java -jar hetu-cli-*-execute.jar --server ip:port --session enable-dynamic-filter=ture --session dynamic-filtering-max-per-driver-row-count=10000 --session dynamic-filtering-max-per-driver-size=1MB

例2（通过JDBC链接openLooKeng）:

Properties properties = new Properties();
properites.setProperties("enable-dynamic-filter", "true");
properites.setProperties("dynamic-filtering-max-per-driver-row-count", "10000");
properites.setProperties("dynamic-filtering-max-per-driver-size", "1MB");
String url = "jdbc:lk://127.0.0.0:8090/hive/default";
Connection connection = DriverManager.getConnection(url, properties);

查询远程数据中心

数据中心连接器为远程数据中心中的每个目录提供一个以属性文件名为前缀的目录。将每个带前缀的远程目录视为本地集群中的独立目录。可以通过执行SHOW CATALOGS来查看可用远程目录：

SHOW CATALOGS;

如果在远程数据中心中有一个名为mysql的目录，则可以通过执行SHOW SCHEMAS来查看远程目录中的模式：

SHOW SCHEMAS FROM dc.mysql;

如果远程目录mysql中有一个名为web的模式，则可以通过执行SHOW TABLES来查看该目录中的表：

SHOW TABLES FROM dc.mysql.web;

可以使用以下方法之一查看web模式中clicks表中的列的列表：

DESCRIBE dc.mysql.web.clicks;
SHOW COLUMNS FROM dc.mysql.web.clicks;

最后，可以访问web模式中的clicks表：

SELECT * FROM dc.mysql.web.clicks;

如果对目录属性文件使用不同的名称，请使用该目录名称，而不要在上述示例中使用dc。

数据中心连接器限制

数据中心连接器是一个只读连接器。暂不支持以下SQL语句：

ALTER SCHEMA、ALTER TABLE、ANALYZE、CACHE TABLE、COMMENT、CREATE SCHEMA、CREATE TABLE、CREATE TABLE AS、CREATE VIEW、DELETE、DROP CACHE、DROP SCHEMA、DROP TABLE、DROP VIEW、GRANT、INSERT、INSERT OVERWRITE、REVOKE、SHOW CACHE、SHOW CREATE VIEW、SHOW GRANTS、SHOW ROLES、SHOW ROLE GRANTS、UPDATE、VACUUM