Flink-SQL 依赖项：如何在 Marven Repo 中查找

Question

我是 apache 平台和 flink 的初学者。我正在尝试查询下面的 Flint-SQL 代码。我有2个问题

1 - 我需要找到连接器“文件系统”（在 Maven 存储库或其他地方） 2 - 是否可以按计划运行这些 Flint-SQL 脚本 flint-jobs

-- Create the input table
CREATE TABLE taxi_rides (
    ride_id BIGINT,
    passenger_count INT,
    start_time TIMESTAMP(3),
    end_time TIMESTAMP(3),
    start_location STRING,
    end_location STRING,
    revenue DOUBLE
) WITH (
    'connector' = 'filesystem',
    'path' = 'file:///home/app/taxi_data.parquet',
    'format' = 'parquet'
);

我需要在Flink中找到依赖连接器和主机

Answer 1

您好，您可以从官方文档中找到很多问题的答案。

文件系统连接器本身包含在 Flink 中，不需要额外的依赖项。相应的jar可以在Flink发行版的/lib目录下找到。

您可以在这里找到：Flink 文档 根据您使用的 Flink 版本选择您的文档版本。

对于每种格式（镶木地板、avro 等），都有专门的页面，其中包含说明和下载库的链接。对于您的情况下的镶木地板。