-
DDL
CREATE TABLE PARTITIONED BY ALTER TABLE ... WRITE DISTRIBUTED BY PARTITION ALTER TABLE ... SET IDENTIFIER FIELDS ALTER TABLE ... DROP IDENTIFIER FIELDS Branching and Taggi... -
Flink DDL
Create catalogs Flink SQL YAML configuration CREATE statement CREATE DATABASE CREATE TABLE PARTITIONED BY CREATE TABLE LIKE DROP statement DROP DATABASE DROP TABLE SHOW ... -
Assert
Description Key Features Options rules [ConfigMap] field_rules [ConfigList] field_name [string] field_type [string | ConfigMap] field_value [ConfigList] rule_type [string] ... -
Yarn 队列管理
背景介绍 如何创建Yarn队列 如何使用可用队列 该功能的相关条目 背景介绍 在实际的生产环境中，针对 Yarn 部署模式 ， 用户通常需要输入 queue 或 queue &labels 来指定 yarn-application 模式下的 Flink 应用程序 或 yarn-session 模式下的 Flink 集群的配置。 在此过程中... -
Flink Configuration
Catalog Configuration Runtime configuration Read options Write options Catalog Configuration A catalog is created and named by executing the following query (replace <catalog... -
Speed Control
Introduction Support Those Engines Configuration Introduction The SeaTunnel provides a powerful speed control feature that allows you to manage the rate at which data is synch... -
quick-start-seatunnel-engine
Step 1: Deployment SeaTunnel And Connectors Step 2: Add Job Config File to define a job Step 3: Run SeaTunnel Application What’s More Step 1: Deployment SeaTunnel And Connect... -
Variable Management
Background Introduction Create Variable Reference variables in Flink SQL Reference variables in args of Flink JAR jobs Background Introduction In the actual production enviro... -
External Link Management
Background How to create the external link Where can see the external link Background In production practice, in order to manage the Flink job properly, there is always a need... -
Kudu
Support Kudu Version Support Those Engines Key features Description Data Type Mapping Source Options Task Example Simple: Multiple Table Changelog 2.2.0-beta 2022-09-26 N...