-
Sqoop
SQOOP 节点 综述 创建任务 任务参数 任务样例 配置 Sqoop 环境 配置 Sqoop 任务节点 查看运行结果 SQOOP 节点 综述 SQOOP 任务类型，用于执行 SQOOP 程序。对于 SQOOP 节点，worker 会通过执行 sqoop 命令来执行 SQOOP 任务。 创建任务 点击项目管理 -> 项目名称 -... -
Configuration Glossary
Table of Contents Properties File Format Creating a Basic Properties File Job Launcher Properties Common Job Launcher Properties SchedulerDaemon Properties CliMRJobLauncher Pr... -
Function
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap always a → (* → a) Parameters valThe value to wrap in a func... -
Function
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap binary unary always a → (* → a) Parameters valThe value to... -
Function
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap always a → (* → a) Parameters valThe value to wrap in a func... -
Post-commit Callback
HTTP Endpoints Kafka Endpoints Pulsar Endpoints Bring your own implementation Apache Hudi provides the ability to post a callback notification about a write commit. This may b... -
5. Data partitioning (sharding)
1. Partitioning (sharding) of Redis based Java objects 2. Partitioning (sharding) of Redis setup This feature available only in Redisson PRO edition. 1. Partitioning (shardin... -
Function
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap binary unary always a → (* → a) Parameters valThe value to... -
Switch
Switch 创建任务 任务参数 任务样例 创建工作流 设置条件 执行 Switch Switch 是一个条件判断节点，依据全局变量 的值和用户所编写的表达式判断结果执行对应分支。 注意 使用 javax.script.ScriptEngine.eval 执行表达式。 创建任务 点击项目管理 -> 项目名称 -> 工作流定义，点击”创建... -
Flink Getting Started
Flink Apache Iceberg supports both Apache Flink ‘s DataStream API and Table API. See the Multi-Engine Support page for the integration of Apache Flink. Feature support Flink...
