Apache Paimon 的 Query Service 使用

Query Service

可以运行Flink流作业来启动表的查询服务，当QueryService存在时，Flink Lookup Join将优先从中获取数据，这将有效地提高查询性能。

Flink SQL

CALL sys.query_service('database_name.table_name', parallelism);
1

Flink Action

/bin/flink run \
    /path/to/paimon-flink-action-0.7.0-incubating.jar \
    query_service \
    --warehouse  \
    --database  \
    --table  \
    [--parallelism ] \
    [--catalog_conf  [--catalog_conf  ...]]
1
2
3
4
5
6
7
8