yql/essentials/udfs/common/python/python3_small/test/cases/Cleanup.sql


1
2
3
4
5
6
7
8
9
10
11
12

--sanitizer ignore memory
$udfScript = @@
import yql
def mapper(records):
    yql.g = records
    for record in records:
        yield dict(yid=b"bla", rnd=0.)
@@;

$udf = Python3::mapper(Callable<(Stream<Struct<key:String, subkey:String, value:String>>)->Stream<Struct<yid:String, rnd:Double>>>, $udfScript);

PROCESS Input using $udf(TableRows());