ydb/yql/essentials/tests/s-expressions/suites/Udf/TopFreq.yqls

#program
(
(let config (DataSource 'config))

(import agg_module '"/lib/yql/aggregate.yqls")
(let list (AsList
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '1))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '4))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '8))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '8))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '8))))
(AsStruct '('key (Int32 '1)) '('value (Just (Int32 '1))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '2))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '2))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '2))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '8))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '8))))
(AsStruct '('key (Int32 '2)) '('value (Just (Int32 '1))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '1))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '2))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '3))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '4))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '5))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '6))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '7))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '8))))
(AsStruct '('key (Int32 '3)) '('value (Just (Int32 '9))))
))
(let res_sink (DataSink 'result))
(let topfreq_traits (Apply (bind agg_module 'topfreq_traits_factory) (TypeOf list) (lambda '(row) (Member row 'value)) (Uint32 '2) (Uint32 '2)))
(let resKey (Aggregate list '('key) '('('topfreq_value topfreq_traits))))
(let world (Write! world res_sink (Key) resKey '('('type))))

(let topfreq_traits2 (Apply (bind agg_module 'topfreq_traits_factory) (TypeOf list) (lambda '(row) (Unwrap (ToString (Member row 'value)))) (Uint32 '2) (Uint32 '2)))
(let resKey (Aggregate list '('key) '('('topfreq_value topfreq_traits2))))
(let world (Write! world res_sink (Key) resKey '('('type))))

(let world (Commit! world res_sink))
(return world)
)