-
工作流定义
创建工作流定义 工作流定义操作功能 单个工作流支持的操作 工作流批量操作 运行工作流 单独运行任务 工作流定时 导入工作流 创建工作流定义 点击项目管理->工作流->工作流定义，进入工作流定义页面，点击“创建工作流”按钮，进入工作流DAG编辑 页面，如下图所示： 工具栏中拖拽 到画板中，新增一个Shell任务,如下图所示： ... -
1. Terminologies
Terminologies Kyuubi JDBC Apache Hive Apache Thrift Server ServerSpace Engine EngineSpace Apache Spark Multi Tenancy High Availability / Load Balance Apache Zookeeper Apa... -
Apache Kafka Connector
依赖 Kafka Source (Consumer) 基础消费示例 高级配置参数 消费多个Kafka实例 消费多个Topic Topic 发现 配置开始消费的位置 指定分区Offset 指定deserializer 返回记录KafkaRecord 指定strategy Kafka Sink (Producer) 容错和语义 多实例k... -
Use Cases
A Streaming Data Lake Near Real-Time Ingestion Incremental Processing Pipelines Unified Batch and Streaming Cloud-Native Tables Schema Management ACID Transactions Efficient ... -
ClickHouse Connector
JDBC synchronous write Write in the normal way Write with Apache StreamPark™ configuration list Write to ClickHouse HTTP async write Write in the normal way Write to ClickHou... -
二进制方式
组件安装 安装夜莺 部署集群 MySQL Redis 时序库 n9e-webapi n9e-server 首先我们来看下面的架构图，夜莺的服务端有两个模块：n9e-webapi 和 n9e-server，n9e-webapi 用于提供 API 给前端 JavaScript 使用，n9e-server 的职责是告警引擎和数据转发器。依赖的组件... -
任务结构
任务总体存储结构 各任务类型存储结构详解 Shell节点 SQL节点 PROCEDURE[存储过程]节点 SPARK节点 MapReduce(MR)节点 Python节点 Flink节点 HTTP节点 DataX节点 Sqoop节点 条件分支节点 子流程节点 依赖(DEPENDENT)节点 任务总体存储结构 在dolphin... -
Alerts and Reports
Requirements Commons In your superset_config.py or superset_config_docker.py Disable dry-run mode In your Dockerfile Slack integration Kubernetes-specific Docker Compose s... -
All Configurations
Externalized Config File Hudi Table Config Hudi Table Basic Configs Spark Datasource Configs Read Options Write Options PreCommit Validator Configurations Flink Sql Configs ... -
Clickhouse Connector
JDBC 同步写入 常规方式写入 Apache StreamPark™ 方式写入 配置信息 写入clickhouse HTTP 异步写入 常规方式写入 Apache StreamPark™ 方式写入 异步写入配置及失败恢复组件配置 写入clickhouse 其他配置 ClickHouse 是一个用于联机分析（OLAP）的列式数据库管...