-
Utilities
_.escape(string) Arguments Returns Example _.identity(value) Arguments Returns Example _.mixin(object) Arguments Example _.noConflict() Returns Example _.parseInt(val... -
本地参数
本地参数 作用域 在任务定义页面配置的参数，默认作用域仅限该任务，如果配置了参数传递 则可将该参数作用到下游任务中。 使用方式 本地参数配置方式如下：在任务定义页面，点击“自定义参数”右边的加号，填写对应的变量名称和对应的值，保存即可。 如果要在单个任务中使用参数，请参阅通过自定义参数使用 如果要在任务中使用配置参数并在下游任务中使用它们： 如果... -
PySpark
Requirements Preparation Prepare JDBC driver Prepare JDBC Hive Dialect extension Including jars of JDBC driver and Hive Dialect extension Usage Using as JDBC Datasource progra... -
Preface
References This book is published by Chapman & Hall/CRC . The online version of this book is free to read here (thanks to Chapman & Hall/CRC), and licensed under the Creative Co... -
Batch Writes
Spark DataSource API The hudi-spark module offers the DataSource API to write a Spark DataFrame into a Hudi table. There are a number of options available: HoodieWriteConfig :... -
ClickhouseFile
Description Key features Options host [string] database [string] table [string] username [string] password [string] sharding_key [string] clickhouse_local_path [string] co... -
Hive
Description Key features Options table_name [string] metastore_uri [string] hdfs_site_path [string] hive_site_path [string] hive.hadoop.conf [map] hive.hadoop.conf-path [str... -
Function
always comparator compose construct curry useWith flip groupBy identity invoker nAry once pipe tap binary unary ap empty of constructN converge curryN __ bin... -
告警自愈模块
概述 架构 项目地址 安装启动 初始化 sql 启动 server 启动agentd Ibex 是告警自愈功能依赖的模块，提供一个批量执行命令的通道，可以做到在告警的时候自动去目标机器执行脚本，如果大家没有此需求，无需阅读本节内容。 概述 所谓的告警自愈，典型手段是在告警触发时自动回调某个 webhook 地址，在这个 webhook 里... -
Flink Writes
Flink Writes Iceberg support batch and streaming writes With Apache Flink ‘s DataStream API and Table API. Writing with SQL Iceberg support both INSERT INTO and INSERT OVERWRIT...
