eachPost

语法

eachPost(func, X, [post], [assembleRule|consistent=false])

func:O(X, [post])X <operator>:O [post] 表示不指定 assembleRule,使用默认值

func:OC(X, [post])X <operator>:OC [post] 表示指定 assembleRule,此例中指定为 C(Consistent)

参数

  • func 是一个二元函数。
  • X 可以是向量、矩阵或表。当 X 是向量时,post 必须是标量;当 X 是矩阵时,post 必须是标量或向量;当 X 是表时,post 是标量或表;当 post 未指定时,结果的最后一个元素为 NULL。
  • post 是可选参数,用于为 X 的最后一个元素提供后序值,其数据形式要求取决于 X 的数据形式。
  • assembleRule 可选参数,表示如何将子任务的结果合并为函数最终结果。接受一个整数或字符串作为输入,可选值如下:
    • 0 (或 "D"):默认值,表示 DolphinDB 规则,即根据所有子任务的结果来决定最终输出的数据类型和形式。当所有子结果具有相同的数据类型和形式时,多个标量合并为一个向量、多个向量合并为一个矩阵、多个矩阵合并为一个元组、多个字典合并为一张表;否则将所有子结果合并为一个元组输出。

    • 1(或 "C"):表示 Consistent 规则,即认为所有子结果的数据类型和形式都与第一个子结果相同,根据第一个子结果来选择最终结果的数据类型和形式。如果后续子任务返回的结果与第一个子任务的结果类型不一致,系统会尝试对后续结果进行类型转换。如果转换失败则抛出异常。因此,此规则只可在已知子结果的数据类型及形式一致时指定。此规则可使系统免于逐一缓存并检查每个子任务的计算结果,从而提升性能。

    • 2(或 "U"):表示 Tuple 规则,系统不再对各子结果的类型和形式一致性进行检查,而是直接将子结果组装成一个元组输出。

    • 3(或 "K"):表示 kdb+ 规则。与 DolphinDB 规则类似,都会根据所有子结果来决定最终结果形式。主要区别在于,kdb+ 规则下,只要有任一子任务返回向量,则最终结果必为一个元组;而在 DolphinDB 规则下,子任务结果若均为长度相同的向量,则最终结果为一个矩阵。其他情况下,kdb+ 规则的输出与 DolphinDB 规则相同。

    注:
    • 自 2.00.15/3.00.3 版本起,新增了 assembleRule 参数。该参数不仅实现了原 consistent 参数的功能,还提供了更多的结果合并选项。consistent 是一个布尔值,默认值为 false,相当于 assembleRule="D";若为 true,则相当于 assembleRule="C"。为保持兼容性,用户仍可使用 consistent 参数。如果同时指定 assembleconsistent,将以 consistent 的值为准。
    • assembleRule 也可在高阶函数对应的函数模式符号后指定,通过字符 D/C/U/K 表示。以 eachPre (:P) 为例,形如 sub:PU(X)。不指定则使用默认值 D。

详情

将给定函数/运算符应用到所有相邻的数据对上。

eachPost 高阶函数等同于:F(X[0], X[1]), F(X[1], X[2]), ..., F(X[n], post).

例子

x=1..10;
eachPost(sub, x);
// output
[-1,-1,-1,-1,-1,-1,-1,-1,-1,]
// 等同于 [1-2, 2-3, ..., 9-10, NULL]

+:O x;
// output
[3,5,7,9,11,13,15,17,19,]
// 等同于 [1+2, 2+3, ..., 9+10, NULL]

x +:O 0;
// output
[3,5,7,9,11,13,15,17,19,10]
// 等同于 [1+2, 2+3, ..., 9+10, 10+0]

x=1..12$3:4;
x;
col1 col2 col3 col4
1 4 7 10
2 5 8 11
3 6 9 12
-:O x;
col1 col2 col3 col4
-3 -3 -3
-3 -3 -3
-3 -3 -3
eachPost(\, x, x[0]);
col1 col2 col3 col4
0.25 0.571429 0.7 10
0.4 0.625 0.727273 5.5
0.5 0.666667 0.75 4
def f1(a,b){
    return (a[`x])+(a[`y])+(b[`x])+(b[`y])
}

t = table(1 2 3 as x,2 3 4 as y)
t1 = table(1 as x,2 as y)
eachPost(f1,t,t1)

// output
(8,12,[10])