HDFS

HDFS 数据库引擎将 HDFS 中的文件以只读表的形式暴露出来。表名通过 hdfs 表函数进行解析。

创建数据库

CREATE DATABASE hdfs_data
ENGINE = HDFS([hdfs_host_and_root_path]);

hdfs_host_and_root_path 为可选项，用于设置 HDFS 基础 URL。设置该项后，表名即为相对于该 URL 的路径；若未设置，表名必须是完整的 hdfs:// URL。

CREATE DATABASE hdfs_data
ENGINE = HDFS('hdfs://namenode:9000/data');

SELECT * FROM hdfs_data.`events.parquet`;

schema 与 format 的推断方式与 hdfs 表函数相同。该数据库不持有任何表定义，也不支持表的 DDL 或写入操作。

HDFS URL 会根据服务器的远程主机过滤器进行校验。无论 table_engines_require_grant 如何设置，创建该数据库都需要具备 HDFS 上的 READ 和 WRITE source 授权，例如：

GRANT READ, WRITE ON HDFS TO user_name;

有关版本和兼容性的详细信息，请参阅 SOURCES 特权。