blob: 523b97853ad50096c92ff35fd83bb663f3f1bcac (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
|
/* postgres can not */
/* syntax version 1 */
use plato;
$udfScript = @@
def AppendInfo(a_name, a_age = None, a_region = None):
res = a_name.decode('utf-8')
if a_age:
res += ", age: " + repr(a_age)
if a_region:
res += ", region: " + repr(a_region)
return res.encode('utf-8')
@@;
$udf = Python3::AppendInfo(Callable<(name:String, [age:Int32?, region:Int32?])->String>, $udfScript);
$data = (select cast(key as int32) as age, cast(subkey as int32) as region, value as name from Input);
select $udf(region as region, name as name) as val from $data;
|