NamedArgUdf.yql 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344
  1. (
  2. #comment
  3. (let config (DataSource 'config))
  4. (let world (Configure! world config 'PureDataSource 'yt))
  5. (let udf (Udf 'SimpleUdf.NamedArgs ))
  6. (let res_sink (DataSink 'result))
  7. (let world (Write! world res_sink (Key) (FormatType (TypeOf udf)) '('('type))))
  8. (let world (Write! world res_sink (Key) (NamedApply udf
  9. '((Uint32 '1))
  10. (AsStruct))
  11. '()))
  12. (let world (Write! world res_sink (Key) (NamedApply udf
  13. '((Uint32 '1) (Uint32 '2))
  14. (AsStruct))
  15. '()))
  16. (let world (Write! world res_sink (Key) (NamedApply udf
  17. '((Uint32 '1))
  18. (AsStruct '('C (Uint32 '3))))
  19. '()))
  20. (let world (Write! world res_sink (Key) (NamedApply udf
  21. '((Uint32 '1))
  22. (AsStruct '('C (Uint32 '3)) '('D (Uint32 '4))))
  23. '()))
  24. (let world (Write! world res_sink (Key) (NamedApply udf
  25. '((Uint32 '1))
  26. (AsStruct '('D (Uint32 '4))))
  27. '()))
  28. (let world (Write! world res_sink (Key) (NamedApply udf
  29. '((Uint32 '1) (Uint32 '2))
  30. (AsStruct '('D (Uint32 '4))))
  31. '()))
  32. (let world (Write! world res_sink (Key) (NamedApply udf
  33. '((Uint32 '1) (Uint32 '2) (Uint32 '3))
  34. (AsStruct))
  35. '()))
  36. (let world (Write! world res_sink (Key) (NamedApply udf
  37. '((Uint32 '1) (Uint32 '2) (Uint32 '3) (Uint32 '4))
  38. (AsStruct))
  39. '()))
  40. (let world (Commit! world res_sink))
  41. (return world)
  42. )