aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/tests/sql/suites/expr/empty_iterator2.sql
blob: 39164341d458d29552c9c51779be1669c363ac3e (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
/* syntax version 1 */
/* postgres can not */
USE plato;

$train =
SELECT key, value FROM Input GROUP BY key, value having key > "900";

$method = ($stream) -> {
    $func = Callable(
        CallableType(0, TypeOf($stream), TypeOf($stream)),
        ($_1) -> { return $_1; }
    );
    RETURN $func($stream);
};

$prediction =
    PROCESS $train
    USING $method(TableRows());

SELECT * FROM $prediction;