blob: b555f9f06ce3fecfc78ec258191d2ec04c5ccd5e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
(
(let $1 (DataSink 'result))
(let $2 (Right! (Read! world (DataSource '"yt" '"plato") (MrTableConcat (Key '('table (String '"Input")))) (Void) '())))
(let inputFlow (ToFlow (PersistableRepr (OrderedSqlProject $2 '((SqlProjectStarItem (TypeOf $2) '"" (lambda '($4) $4) '()))))))
(let timeOrderRecover (TimeOrderRecover
inputFlow
(lambda '($3) (Member $3 '"ts"))
(Interval '-10)
(Interval '5)
(Uint32 '12)
))
(let $3 (Write! world $1 (Key)(ForwardList timeOrderRecover)'('('type) '('autoref))))
(return (CommitAll! (Commit! $3 $1)))
)
|
