Appendix Shell SubProcess Dependent Stored Procedure SQL Spark MapReduce Python Flink HTTP DataX Pigeon Conditions Switch SeaTunnel Amazon EMR Apache Zeppelin Jup...

任务定义 任务定义 任务定义允许您在基于任务级别而不是在工作流中操作修改任务。再此之前，我们已经有了工作流级别的任务编辑器，你可以在工作流定义 单击特定的工作流，然后编辑任务的定义。当您想编辑特定的任务定义但不记得它属于哪个工作流时，这是令人沮丧的。所以我们决定在 任务 菜单下添加 任务定义 视图。 在该视图中，您可以通过单击 操作 列中...

任务总体存储结构 各任务类型存储结构详解 Shell节点 SQL节点 PROCEDURE[存储过程]节点 SPARK节点 MapReduce(MR)节点 Python节点 Flink节点 HTTP节点 DataX节点 Sqoop节点 条件分支节点 子流程节点 依赖(DEPENDENT)节点 任务总体存储结构 在dolphin...

> 任务对象 “立即检查”请求对象 “诊断信息”请求对象 统计请求对象 每种类型的诊断信息请求可用的统计字段列表 可用于每种诊断信息请求的排序字段列表 统计结果对象 > 任务对象 以下对象都是与 task 直接相关的API。 任务对象具有以下属性: 属性 类型 描述 taskid string (只读) 任务的ID。 type ...

任务操作 处理任务请求 提交execute函数 结束任务 结束Jobs 任务日志 暂停任务 任务进展 资源进展 任务状态 任务操作 EntranceRestfulApi 类 处理任务请求 接口地址 :/api/rest_j/v1/entrance/execute 请求方式 :POST 请求数据类型 :applicatio...

数据同步 实时采集 Flink SQL Spark SQL Hive SQL

任务管理 1. 概要 2. 任务列表 3. 创建任务 4. 查看任务详情 5. 启停用任务 6. 删除任务 7. cron表达式填写说明 表达式结构 各字段及符号含义 Cron 表达式案例 8. 更多操作 任务管理 1. 概要 任务，按时间点或者周期性执行的任务。它实现了任务执行程序和触发器之间的关联。一个具体的任务，配置任...

任务处理 了解 Marathon 任务类别 终端状态 非终端状态 配置任务处理 任务处理 了解 Marathon 任务类别 Marathon 将任务分为三类：初始、非终端和终端。这些类别中的任务可能处于下图所示的一种状态。要了解任务的状态，可以查看 DC/OS 日志或查询 Marathon API (/v2/events) 的事件流 。...

运行任务 运行任务 运行任务的详细情况请参考 运行爬虫 。

任务投递 实例 异步任务监听器 任务投递 任务可投递协程和异步，如果是异步需要定义监听器，处理任务执行结果数据。 实例 use Swoft \Task\Task ; $result = Task :: deliver ( 'demo' , 'coroutineJob' , [ 'p1' , 'p2' ], ...