Зависимости Flink-SQL: как найти в Marven Repo ⇐ JAVA

[Anonymous]

Я новичок в работе с платформами Apache и Flink. Я пытаюсь выполнить запрос ниже кода Flink-SQL. У меня 2 вопроса

• Мне нужно найти соединитель «файловая система» (в репозитории maven или где-то еще).
• Есть ли эти сценарии Flink-SQL можно запускать как запланированные задания flink

Код: Выделить всё

    -- 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


Подробнее здесь: https://stackoverflow.com/questions/792 ... arven-repo