集計関数

たとえば、出発地と目的地の各組み合わせ間の距離を計算するには、次のステートメントを使用します。

1a1 = group a by (origin, dest);
2a2 = foreach a1 generate origin as origin, dest as destination, first(miles) as miles;

たとえば、出発地と目的地の各組み合わせ間の距離を計算するには、次のステートメントを使用します。

1a1 = group a by (origin, dest);
2a2 = foreach a1 generate origin as origin, dest as destination, last(miles) as miles;

この関数は、引数として基準のみを取ります。ディメンションを取ることはできません。

式には「xInt」や「price」など任意の識別子を使用できますが、price/100 または ceil(distance) などの複雑な式や、2.5 などのリテラルは使用できません。

1q = load "data/airline";
2q = group q by dest;
3q = foreach q generate dest, median(miles) as medMiles;
4limit q 5;

1q = load "data/airline";
2q = foreach q generate dest, median(miles) as medMiles;
3limit q 5;

この関数は、引数として基準のみを取ります。ディメンションを取ることはできません。

たとえば、航空会社の出発地数と目的地数を調べるには、次のステートメントを使用します。

1a1 = group a by carrier;
2a2 = foreach a1 generate carrier as carrier, unique(origin) as origins, unique(dest) as destinations;

グループ化された数値型の式を受け入れます。グループ内の null 以外の値の数が 1 の場合、stddev は null を返します。それ以外の場合、stddev はグループで計算された標本標準偏差を返します (null 値は無視)。

式には「xInt」や「price」など任意の数値識別子を使用できますが、price/100 または ceil(price) などの複雑な式や、2.5 などのリテラルは使用できません。

1q = load "data/airline";
2q = group q by dest;
3q = foreach q generate dest, stddev(miles) as stddevMiles;
4limit q 5;

グループ化された数値型の式を受け入れ、グループで計算された母標準偏差を返します (null 値は無視)。式には「xInt」や「price」など任意の数値識別子を使用できますが、price/100 または ceil(price) などの複雑な式や、2.5 などのリテラルは使用できません。

1q = load "data/airline";
2q = group q by dest;
3q = foreach q generate dest, stddevp(miles) as stddevMiles;
4limit q 5;

グループ化された数値型の式を受け入れます。グループ内の null 以外の値の数が 1 の場合、var は null を返します。それ以外の場合、var はグループで計算された標本分散を返します (null 値は無視)。式には「xInt」や「price」など任意の数値識別子を使用できますが、price/100 または ceil(price) などの複雑な式や、2.5 などのリテラルは使用できません。

1q = load "data/airline";
2q = group q by dest;
3q = foreach q generate dest, var(miles) as varMiles;
4limit q 5;

グループ化された数値型の式を受け入れ、グループで計算された母分散を返します (null 値は無視)。式には「xInt」や「price」など任意の数値識別子を使用できますが、price/100 または ceil(price) などの複雑な式や、2.5 などのリテラルは使用できません。

1q = load "data/airline";
2q = group q by dest;
3q = foreach q generate dest, varp(miles) as varMiles;
4limit q 5;

percentile_disc(p as numeric) within group (order by expr [asc | desc])

percentile_disc 関数はグループ化された数値型の式 expr を受け入れ、指定された順序 (asc または desc) で並び替えます。順序が指定されていない場合、デフォルトの順序は asc です。並び替えた順序でグループ内の値の (100*p)% の位置にある値を返します (null 値は無視)。

p には、小数点以下 8 桁の精度を持つ 0 ～ 1 の任意の実数値を指定できます。expr には「xInt」や「price」など任意の識別子を使用できますが、price/100 または ceil(distance) などの複雑な式や、2.5 などのリテラルは使用できません。

expr に正確な 100*p パーセントの位置の値がない場合、percentile_disc は並び替え順で expr の次の位置にある値を返します。

たとえば、Mea1 に値 [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13] が含まれる場合、次の値が返されます。

1percentile_disc(0.25) within group (order by Mea1 asc) = 4
2percentile_disc(0.25) within group (order by Mea1 desc) = 9
3percentile_disc(0) within group (order by Mea1 asc) = 0
4percentile_disc(1) within group (order by Mea1 asc) = 13

クエリ例:

1q = load "data/airline";
2q = group q by dest;         
3q = foreach q generate dest, percentile_disc(0.25) within group (order by miles desc) as perMiles;
4limit q 5;

percentile_cont(p as numeric) within group (order by expr [asc | desc])

percentile_cont 関数はグループ化された数値型の式 expr を受け入れ、指定された順序 (asc または desc) で並び替えます。順序が指定されていない場合、デフォルトの順序は asc です。並び替えた順序でグループ内の値の (100*p)% の位置にある値を返します (null 値は無視)。

p には、0 ～ 1 の任意の実数値を指定できます。expr には「xInt」や「price」など任意の識別子を使用できますが、price/100 または ceil(distance) などの複雑な式や、2.5 などのリテラルは使用できません。

expr に正確な 100*p パーセントの位置の値がない場合、percentile_cont は expr 内でその位置に最も近い 2 つの値から線形補間された値を返します。

たとえば、Mea1 に値 [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13] が含まれる場合、次の値が返されます。

1percentile_cont(0.25) within group (order by Mea1 asc) = 3.25
2percentile_cont(0.25) within group (order by Mea1 desc) = 9.75
3percentile_cont(0) within group (order by Mea1 asc) = 0
4percentile_cont(1) within group (order by Mea1 asc) = 13

クエリ例:

1q = load "data/airline";
2q = group q by dest;
3q = foreach q generate dest, percentile_cont(0.25) within group (order by miles) as perMiles;
4limit q 5;

単純な線形回帰関数 regr_slope は、グループ化した連動数値式 y およびグループ化した独立数値式 x を受け入れ、回帰直線の傾きを返します。regr_slope 関数では、両方とも null ではない (x, y) 値のペアのみが考慮され、指定グループ内に存在する該当ペアが 2 個未満の場合は null が返されます。単純な線形回帰関数は、単純なグループ化された値の集計関数のように機能しますが、共通グループでは機能しません。

クエリ例:

1q = load "data/sales";
2q = group q by all;
3q = foreach q generate regr_slope('profit', 'sales') as slope;
4limit q 1;

単純な線形回帰関数 regr_intercept は、グループ化した連動数値式 y およびグループ化した独立数値式 x を受け入れ、回帰直線の Y 切片を返します。regr_intercept 関数では、両方とも null ではない (x, y) 値のペアのみが考慮され、指定グループ内に存在する該当ペアが 2 個未満の場合は null が返されます。単純な線形回帰関数は、単純なグループ化された値の集計関数のように機能しますが、共通グループでは機能しません。

クエリ例:

1q = load "data/sales";
2q = group q by all;
3q = foreach q generate regr_intercept('profit', 'sales') as intercept;
4limit q 1;

単純な線形回帰関数 regr_r2 は、グループ化した連動数値式 y およびグループ化した独立数値式 x を受け入れ、決定係数 (R 二乗または適合度とも呼ばれる) を返します。regr_r2 関数では、両方とも null ではない (x, y) 値のペアのみが考慮され、指定グループ内に存在する該当ペアが 2 個未満の場合は null が返されます。単純な線形回帰関数は、単純なグループ化された値の集計関数のように機能しますが、共通グループでは機能しません。

クエリ例:

1q = load "data/sales";
2q = group q by all;
3q = foreach q generate regr_r2('profit', 'sales') as r2;
4limit q 1;