process_with_python_stream.sql 473 B

1234567891011121314151617181920212223
  1. /* syntax version 1 */
  2. /* kikimr can not */
  3. USE plato;
  4. $udfScript = @@
  5. def f(input,x):
  6. for i in input:
  7. yield {
  8. 'key': i.key,
  9. 'subkey': i.subkey,
  10. 'value': i.value,
  11. 'pass': x
  12. }
  13. @@;
  14. $udf_stream = Python3::f(
  15. Callable<
  16. (Stream<Struct<key:String,subkey:String,value:String>>,Int32)
  17. ->
  18. Stream<Struct<key:String,subkey:String,value:String,pass:Int32>>
  19. >, $udfScript);
  20. PROCESS Input0 using $udf_stream(TableRows(), 2);