(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '@@["StructType";[["a";["OptionalType";["DataType";"Int64"]]];["b";["OptionalType";["DataType";"Uint64"]]];["c";["OptionalType";["DataType";"Double"]]];["d";["OptionalType";["DataType";"String"]]];["e";["OptionalType";["DataType";"Bool"]]];["f";["OptionalType";["DataType";"Yson"]]]]]@@)
(let $3 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $2)))
(let $4 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" 'false)))))
(let $5 (YtStat '('Id '"Input") '('RecordsCount '"5") '('DataSize '"216") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
(let $6 (YtTable '"Input" $3 $4 $5 '() (Void) (Void) '"/Root/plato"))
(let $7 (DqPhyStage '() (lambda '() (block '(
  (let $21 '('"a" '"b" '"c" '"d" '"e" '"f"))
  (let $22 (YtReadTable! world $1 '((YtSection '((YtPath $6 $21 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (WideFilter (DqReadWideWrap $22 '()) (lambda '($23 $24 $25 $26 $27 $28) (Coalesce $27 (Bool 'false)))) (lambda '($29 $30 $31 $32 $33 $34) (AsStruct '('"a" $29) '('"b" $30) '('"c" $31) '('"d" $32) '('"e" $33) '('"f" $34))))))
))) '('('"_logical_id" '1458) '('"_id" '"50b52849-cdeb2d1f-d4899fab-193ae5b8"))))
(let $8 (DqCnUnionAll (TDqOutput $7 '0)))
(let $9 (DqPhyStage '($8) (lambda '($35) $35) '('('"_logical_id" '1584) '('"_id" '"45af93e1-25565661-a7a4573d-afaa55b0"))))
(let $10 (DqCnResult (TDqOutput $9 '0) '()))
(let $11 '('('"type" '"generic")))
(let $12 (KqpPhysicalTx '($7 $9) '($10) '() $11))
(let $13 (DqPhyStage '() (lambda '() (block '(
  (let $36 (YtReadTable! world $1 '((YtSection '((YtPath $6 '('"a" '"e") (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (WideFilter (DqReadWideWrap $36 '()) (lambda '($37 $38) (Not (Coalesce $38 (Bool 'true))))) (lambda '($39 $40) (AsStruct '('"a" $39))))))
))) '('('"_logical_id" '1537) '('"_id" '"5e77d26-e3f7b695-d08e59f7-4599b42a"))))
(let $14 (DqCnUnionAll (TDqOutput $13 '0)))
(let $15 (DqPhyStage '($14) (lambda '($41) $41) '('('"_logical_id" '1770) '('"_id" '"5a56d3be-bd8941c0-aff155c4-1df62ba8"))))
(let $16 (DqCnResult (TDqOutput $15 '0) '('"a")))
(let $17 (KqpPhysicalTx '($13 $15) '($16) '() $11))
(let $18 '('"a" (OptionalType (DataType 'Int64))))
(let $19 (KqpTxResultBinding (ListType (StructType $18 '('"b" (OptionalType (DataType 'Uint64))) '('"c" (OptionalType (DataType 'Double))) '('"d" (OptionalType (DataType 'String))) '('"e" (OptionalType (DataType 'Bool))) '('"f" (OptionalType (DataType 'Yson))))) '0 '0))
(let $20 (KqpTxResultBinding (ListType (StructType $18)) '1 '0))
(return (KqpPhysicalQuery '($12 $17) '($19 $20) '('('"type" '"query"))))
)
