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

任务总体存储结构 各任务类型存储结构详解 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

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

定义任务 注解 实例 定义任务 一个类就是一个任务组，类里面的每个方法，就是一个任务。 注解 @Task name 定义任务名称，缺省时类名，用于投递任务，且必须唯一 coroutine 是否启动一个协程运行业务逻辑，缺省是false (由于Swoole的TaskWorker尚不支持运行协程代码，顾此选项目前仅做预留) 实例 /...

DM 任务配置文件介绍 关键概念 配置顺序 全局配置 基础信息配置 功能配置集 示例配置 DM 任务配置文件介绍 本文档主要介绍 Data Migration (DM) 的任务配置文件 task.yaml ，包含全局配置 和实例配置 两部分。 关于各配置项的功能和配置，请参阅数据同步功能 。 关键概念 关于包括 source...

Scheduler 特性 开发指南 注册Scheduler组件 实现自定义Job execute方法说明 注册Job job的字段说明 任务调度 EduSoho的任务调度方式 job运行状态变迁 配置方法 Linux & Mac OS Windows 任务计划时间间隔问题 Scheduler Scheduler 即定时任务...

任务调度 简介 启动调度器 定义调度 Artisan 命令调度 队列任务调度 Shell 命令调度 调度频率设置 时间范围限制 闭包测试限制 环境约束 时区 避免任务重复 任务只运行在一台服务器上 后台任务 维护模式 任务输出 任务钩子 Ping 网址 任务调度 简介 定义调度 Artisan 命令调度 队...