ydb/library/yql/tests/sql/suites/produce/process_with_python.sql


1
2
3
4
5
6
7
8
9
10

/* postgres can not */
/* syntax version 1 */
$udfScript = @@
def Dup(s):
    return [{"value":s},{"value":s}]
@@;

$udf = Python::Dup(Callable<(String)->List<Struct<value:String>>>, $udfScript);

process plato.Input0 using $udf(value);