e作为Netty的客户端，内部NettyClient实现客户端功能。 发布者 通过NettySink向下游Job发送数据的Job称为发布者。 订阅者 通过NettySource接收上游Job发送的数据的Job称为订阅者。 注册 服务器 保存NettyServer的IP、端口以及Ne

查看更多 →

PG_JOB_PROC PG_JOB_PROC系统表对应12.2.15.45 PG_JOB表中每个任务的作业内容（包括：PL/SQL代码块、匿名块）。将存储过程信息独立出来，是因为如果放到PG_JOB中，被加载到共享内存的时候，会占用不必要的空间，所以在使用的时候再进行查询获取。普通用户需授权才能访问。

查看更多 →

PG_JOB_PROC PG_JOB_PROC系统表对应12.2.15.45 PG_JOB表中每个任务的作业内容（包括：PL/SQL代码块、匿名块）。将存储过程信息独立出来，是因为如果放到PG_JOB中，被加载到共享内存的时候，会占用不必要的空间，所以在使用的时候再进行查询获取。普通用户需授权后才能访问。

查看更多 →

PG_JOB_PROC PG_JOB_PROC视图用于代替之前版本的PG_JOB_PROC系统表，提供对之前版本的前向兼容。原PG_JOB_PROC系统表已经和原PG_JOB系统表一同并入当前版本的PG_JOBS系统表，关于PG_JOBS系统表的描述详见PG_JOBS。 表1 PG_JOB_PROC字段

查看更多 →

查询job列表 功能介绍 异步任务jobId返回后，若jobId业务层丢失无法通过接口重新获取，现在提供一个新的接口用于查询engine中保存的所有异步任务，返回每个任务的jobId、job状态、原始请求。 图规格为持久化版的图，目前最多返回100000条请求。 URI GET /ges/v1

查看更多 →

next_marker String 翻页时，作为后一页的marker取值 previous_marker String 翻页时，作为前一页的marker取值 current_count Integer 当前页的数据总数 请求示例 查询Job列表 GET https://{Endpoint

查看更多 →

PG_JOB_PROC PG_JOB_PROC系统表对应PG_JOB表中每个任务的作业内容（包括：PL/SQL代码块、匿名块）。将存储过程信息独立出来，是因为如果放到PG_JOB中，被加载到共享内存的时候，会占用不必要的空间，所以在使用的时候再进行查询获取。 表1 PG_JOB_PROC字段

查看更多 →

PG_JOB_PROC PG_JOB_PROC系统表对应PG_JOB表中每个任务的作业内容（包括：PL/SQL代码块、匿名块）。将存储过程信息独立出来，是因为如果放到PG_JOB中，被加载到共享内存的时候，会占用不必要的空间，所以在使用的时候再进行查询获取。 表1 PG_JOB_PROC字段

查看更多 →

否 Integer 查询的偏移量。 limit 否 Integer 单次查询的大小[1-100]。 instance_id 否 String 实例ID。 app_id 否 String 应用ID。 target 否 String 安装实例的用户。 job_status 否 String

查看更多 →

job.properties 功能描述 流程的属性定义文件，定义了流程运行期间使用的外部参数值对。 参数解释 “job.properties”文件中包含的各参数及其含义，请参见表1。 表1 参数含义 参数 含义 nameNode HDFS NameNode集群地址 resourceManager

查看更多 →

查询Job状态(1.0.0)-管理面 功能介绍 查询Job的执行状态。对创建图、关闭图、启动图、删除图、导入图等异步API命令下发后，会返回jobId，通过jobId查询任务的执行状态。 调试 您可以在 API Explorer 中调试该接口，支持自动认证鉴权。API Explore

查看更多 →

s?offset=0&limit=2 SERVER_URL：图的访问地址，取值请参考业务面API使用限制。 不同的job_id调用接口得到的结果也不同。 响应示例 状态码： 200 成功响应示例 Http Status Code: 200 { "data": {

查看更多 →

failed：完全失败 partFailed：部分成功 cause String 导入失败原因。 totalLines Long 导入的总行数，以您的配额以及所创图的规格为准。其值为-1时表示当前版本没有返回该字段。 failedLines Long 导入失败行数。其值为-1时表示当前版本没有返回该字段。

查看更多 →

上述重建的SQL只需要修改第一行（Use [dbname]），修改为指定的数据库即可。 如果需要对所有库执行，请修改SQL，添加多所有库的循环执行，此处不做详细示例。 选择“Schedules”，单击“New”，添加定时执行计划。 图3 添加定时执行计划 添加每个月执行一次的定时计

查看更多 →

varying(128) 参数所属作业的拥有者。 job_name character varying(128) 参数所属作业名。 argument_name character varying(128) 参数名称。 argument_position numeric 参数在参数列表中的位置。 argument_type

查看更多 →

varying(128) 参数所属作业的拥有者。 job_name character varying(128) 参数所属作业名。 argument_name character varying(128) 参数名称。 argument_position numeric 参数在参数列表中的位置。 argument_type

查看更多 →

参数在参数列表中的位置。 argument_type character varying(257) 参数的数据类型，可以是用户的自定义数据类型。 value character varying(4000) 参数值。 anydata_value character varying(4000)

查看更多 →

input.fileinputformat.split.maxsize map输入信息应被拆分成的数据块的最大大小。 由用户定义的分片大小的设置及每个文件block大小的设置，可以计算分片的大小。计算公式如下： splitSize = Math.max(minSize, Math.min(maxSize

查看更多 →

数据订阅是获取数据库中关键业务的数据变化信息，并将其缓存并提供统一的SDK接口，方便下游业务订阅、获取、并消费，其支持的数据库和订阅的数据类型如表25所示，更多数据订阅的功能特性可参考数据订阅。 表25 数据库信息 数据库引擎 支持订阅的数据类型 RDS for MySQL 5.6、5.7版本 数据更新

查看更多 →

input.fileinputformat.split.maxsize map输入信息应被拆分成的数据块的最大大小。 由用户定义的分片大小的设置及每个文件block大小的设置，可以计算分片的大小。计算公式如下： splitSize = Math.max(minSize, Math.min(maxSize

查看更多 →

job.properties 功能描述 流程的属性定义文件，定义了流程运行期间使用的外部参数值对。 参数解释 “job.properties”文件中包含的各参数及其含义，请参见表1。 表1 参数含义 参数 含义 nameNode HDFS NameNode集群地址 resourceManager

查看更多 →