From 0f9b7395a110220ace0aa24315e60394c7ad2aae Mon Sep 17 00:00:00 2001 From: SisMaker <156736github> Date: Mon, 4 Jul 2022 23:27:26 +0800 Subject: [PATCH] =?UTF-8?q?ft:=20=E4=BB=A3=E7=A0=81=E4=BC=98=E5=8C=96?= =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/agApi/agPregel.erl | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/src/agApi/agPregel.erl b/src/agApi/agPregel.erl index 708c15b..491c119 100644 --- a/src/agApi/agPregel.erl +++ b/src/agApi/agPregel.erl @@ -65,6 +65,28 @@ status(PoolNameOrSocket, PregelId) -> Path = <<"/_api/control_pregel/", (agMiscUtils:toBinary(PregelId))/binary>>, agVstCli:callAgency(PoolNameOrSocket, ?AgGet, Path). +``% 获取当前正在运行的 Pregel 作业 +% 获取当前正在运行的 Pregel 作业的概述 +% GET /_api/control_pregel +% 返回当前正在运行和最近完成的 Pregel 作业的列表,而不检索它们的结果。返回的对象是 Pregel 职位描述的 JSON 数组。每个职位描述都是一个 JSON 对象,具有以下属性: +% id:Pregel 作业的 id,作为字符串。 +% algorithm:作业使用的算法。 +% created:创建作业的日期和时间。 +% expires:作业结果过期的日期和时间。到期日期仅对已完成、取消或导致错误的作业有意义。当此类作业达到其到期日期/时间时,垃圾收集器会对其进行清理。 +% ttl:作业结果的 TTL(生存时间)值,以秒为单位。TTL 用于计算作业结果的到期日期。 +% state:执行的状态,作为一个字符串。 +% gss:执行了许多全局超级步骤。 +% totalRuntime:到目前为止执行的总运行时间(如果执行仍在进行中)。 +% startupTime:执行的启动运行时。启动时间包括数据加载时间,并且可能很长。如果启动仍在进行中,则启动时间报告为 0。 +% 计算时间:算法执行时间。如果计算仍在进行,则计算时间报告为 0。 +% storageTime:如果作业包含结果存储,则存储结果的时间。如果存储结果仍在进行中,则存储时间报告为 0。 +% 报告:有关 Pregel 执行的可选统计信息。该值仅在算法完成时填充。 +% 回应 +% HTTP 200 : 成功获取作业列表时返回。 +getRunning(PoolNameOrSocket) -> + Path = <<"/_api/control_pregel">>, + agVstCli:callAgency(PoolNameOrSocket, ?AgGet, Path). + % 取消正在进行的 Pregel 执行 % DELETE /_api/control_pregel/{id} % 查询参数