-
RocketMQ
Support Apache RocketMQ Version Support These Engines Key Features Description Sink Options partition.key.fields [array] Task Example Fake to Rocketmq Simple Rocketmq To Roc... -
Hudi
Support Those Engines Key Features Description Supported DataSource Info Data Type Mapping Source Options Task Example Simple: Changelog 2.2.0-beta 2022-09-26 Hudi sour... -
Yarn Queue Management
Background How to create yarn queues How to use available queues Items about the feature Background In the actual production environment for the Yarn Deployment Mode , users... -
Kubernetes PVC Resource usage
Resource usage instructions of K8s PVC Resource usage instructions of K8s PVC The support for pvc resource(mount file resources such as checkpoint/savepoint/logs and so on) is b... -
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 ... -
任务类型
Appendix Shell SubProcess Dynamic Dependent Stored Procedure SQL Spark MapReduce Python Flink HTTP DataX Sqoop Pigeon Conditions Switch SeaTunnel Amazon EMR Apac... -
HdfsFile
Support Those Engines Key Features Description Supported DataSource Info Sink Options Tips Task Example Simple: For orc file format simple config For text file format with ... -
Assert
Description Key Features Options rules [ConfigMap] field_rules [ConfigList] field_name [string] field_type [string | ConfigMap] field_value [ConfigList] rule_type [string] ... -
Flink DataStream
Reading with DataStream Batch mode Streaming mode Streaming mode (LogStore) Streaming mode (FileStore) Writing with DataStream Overwrite data Appending data Reading with ...