(
(let $1 (lambda '() (block '(
  (let $19 '@@["StructType";[["na";["DataType";"Date"]];["nd";["DataType";"Datetime"]];["nt";["DataType";"Timestamp"]];["naz";["DataType";"TzDate"]];["ndz";["DataType";"TzDatetime"]];["ntz";["DataType";"TzTimestamp"]];["wa";["DataType";"Date32"]];["wd";["DataType";"Datetime64"]];["wt";["DataType";"Timestamp64"]];["ni";["DataType";"Interval"]];["wi";["DataType";"Interval64"]];["i8";["DataType";"Int8"]];["u8";["DataType";"Uint8"]];["i16";["DataType";"Int16"]];["u16";["DataType";"Uint16"]];["i32";["DataType";"Int32"]];["u32";["DataType";"Uint32"]];["i64";["DataType";"Int64"]];["u64";["DataType";"Uint64"]];["waz";["DataType";"TzDate32"]];["wdz";["DataType";"TzDatetime64"]];["wtz";["DataType";"TzTimestamp64"]]]]@@)
  (let $20 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $19)))
  (let $21 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $22 (YtStat '('Id '"Dates") '('RecordsCount '1) '('DataSize '"376") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $23 (YtTable '"Dates" $20 $21 $22 '() (Void) (Void) '"/Root/plato"))
  (let $24 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $23 '('"ni" '"wi") (Void) (Void))) '()))))
  (return (FromFlow (DqReadWideWrap $24 '())))
))))
(let $2 '('"_logical_id" '1532))
(let $3 (DataType 'Interval))
(let $4 (DataType 'Interval64))
(let $5 '('"_wide_channels" (StructType '('"ni" $3) '('"wi" $4))))
(let $6 '($2 '('"_id" '"471785c0-ad9af242-7151d40a-e97ebf18") $5))
(let $7 (DqPhyStage '() $1 $6))
(let $8 '($2 '('"_id" '"5b8dc551-35cabfcf-5d37c705-4dd3ab2e") $5))
(let $9 (DqPhyStage '() $1 $8))
(let $10 (DqCnMap (TDqOutput $7 '0)))
(let $11 (DqCnBroadcast (TDqOutput $9 '0)))
(let $12 (DqPhyStage '($10 $11) (lambda '($25 $26) (block '(
  (let $27 (Condense1 (NarrowMap (ToFlow $26) (lambda '($28 $29) (AsStruct '('"ni" $28) '('"wi" $29)))) (lambda '($30) (AsList $30)) (lambda '($31 $32) (Bool '"false")) (lambda '($33 $34) (Append $34 $33))))
  (return (FromFlow (Map (FlatMap $27 (lambda '($35) (NarrowFlatMap (ToFlow $25) (lambda '($36 $37) (Map (Collect $35) (lambda '($38) (AsStruct '('"a.ni" $36) '('"a.wi" $37) '('"b.ni" (Member $38 '"ni")) '('"b.wi" (Member $38 '"wi"))))))))) (lambda '($39) (block '(
    (let $40 (Member $39 '"a.ni"))
    (let $41 (Member $39 '"b.ni"))
    (let $42 (Member $39 '"b.wi"))
    (let $43 (Member $39 '"a.wi"))
    (return (AsStruct '('"column0" (+ $40 $41)) '('"column1" (+ $40 $42)) '('"column2" (+ $43 $41)) '('"column3" (+ $43 $42))))
  ))))))
))) '('('"_logical_id" '1486) '('"_id" '"ac2a160c-904884f1-292babd8-efa31c9b"))))
(let $13 (DqCnUnionAll (TDqOutput $12 '0)))
(let $14 (DqPhyStage '($13) (lambda '($44) $44) '('('"_logical_id" '1804) '('"_id" '"1f87aeb5-8f948ea1-bedacd94-13e1ff5a"))))
(let $15 '($7 $9 $12 $14))
(let $16 '('"column0" '"column1" '"column2" '"column3"))
(let $17 (DqCnResult (TDqOutput $14 '0) $16))
(let $18 (OptionalType $4))
(return (KqpPhysicalQuery '((KqpPhysicalTx $15 '($17) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType '('"column0" (OptionalType $3)) '('"column1" $18) '('"column2" $18) '('"column3" $18))) '0 '0)) '('('"type" '"query"))))
)
