aboutsummaryrefslogtreecommitdiffstats
path: root/yql/essentials/tests/s-expressions/suites/SingleYamrOperation/program14.yql
blob: 218e366ef942e6666da1a820f8fc0ff0d88fde33 (plain) (blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
(
(let sink (DataSink 'yt 'plato))
(let source (DataSource 'yt 'plato))
(let table (Right! (Read! world source (Key '('table (String 'Input))) '('key 'subkey 'value) '())))
(let filter (lambda '(item) (block '(
  (let res (And (> (Member item 'value) (String 'd)) (< (Member item 'key) (String '100))))
  (return res)
)
)))
(let table (Filter table filter))
(let world (Write! world sink (Key '('table (String 'Output))) table '('('mode 'append))))
(let world (Commit! world sink))
(return world)
)