Flink Configuration Catalog Configuration A catalog is created and named by executing the following query (replace <catalog_name> with your catalog name and <config_key> =<confi...
存储过程节点 任务参数 存储过程节点 根据选择的数据源,执行存储过程。 拖动工具栏中的PROCEDURE 任务节点到画板中,如下图所示: 前提:在该数据库里面创建存储过程,如: CREATE PROCEDURE dolphinscheduler . test ( in in1 INT , out out1 I...
Set Flink configuration information in the job How to set up a simple Flink job How to run a job in a project Flink is a powerful high-performance distributed stream processing...
Redisson is the Java Client and Real-Time Data Platform for Redis or Valkey . Providing the most convenient and easiest way to work with Redis or Valkey. Redisson objects provide ...
Spark DDL To use Iceberg in Spark, first configure Spark catalogs . Iceberg uses Apache Spark’s DataSourceV2 API for data source and catalog implementations. CREATE TABLE Spark...