(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '@@["StructType";[["s";["DataType";"String"]];["u";["DataType";"Utf8"]];["y";["DataType";"Yson"]];["j";["DataType";"Json"]];["jd";["DataType";"JsonDocument"]];["ud";["DataType";"Uuid"]];["tzd";["DataType";"TzDate"]];["tzdt";["DataType";"TzDatetime"]];["tzts";["DataType";"TzTimestamp"]]]]@@)
(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 '1) '('DataSize '"174") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
(let $6 (YtTable '"Input" $3 $4 $5 '() (Void) (Void) '"/Root/plato"))
(let $7 (DqPhyStage '() (lambda '() (block '(
  (let $25 '('"j" '"jd" '"s" '"u" '"y"))
  (let $26 (YtReadTable! world $1 '((YtSection '((YtPath $6 $25 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $26 '()) (lambda '($27 $28 $29 $30 $31) (AsStruct '('"column0" (ToPg $29)) '('"column1" (ToPg $30)) '('"column2" (ToPg $31)) '('"column3" (ToPg $27)) '('"column4" (ToPg $28)))))))
))) '('('"_logical_id" '1564) '('"_id" '"b1d8bab2-9312bfce-83ff37ee-dc48f4ac"))))
(let $8 (DqCnUnionAll (TDqOutput $7 '0)))
(let $9 (DqPhyStage '($8) (lambda '($32) $32) '('('"_logical_id" '1724) '('"_id" '"7509eea4-2e7b90f4-53ed5202-bad4bb1a"))))
(let $10 '('"column0" '"column1" '"column2" '"column3" '"column4"))
(let $11 (DqCnResult (TDqOutput $9 '0) $10))
(let $12 '('('"type" '"generic")))
(let $13 (KqpPhysicalTx '($7 $9) '($11) '() $12))
(let $14 (DqPhyStage '() (lambda '() (block '(
  (let $33 '('"tzd" '"tzdt" '"tzts" '"ud"))
  (let $34 (YtReadTable! world $1 '((YtSection '((YtPath $6 $33 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $34 '()) (lambda '($35 $36 $37 $38) (AsStruct '('"column0" (ToPg $35)) '('"column1" (ToPg $36)) '('"column2" (ToPg $37)) '('"column3" (ToPg $38)))))))
))) '('('"_logical_id" '1672) '('"_id" '"99f375a1-5ce3f94d-836a17f5-828f657b"))))
(let $15 (DqCnUnionAll (TDqOutput $14 '0)))
(let $16 (DqPhyStage '($15) (lambda '($39) $39) '('('"_logical_id" '1953) '('"_id" '"d7f4f0ca-ec7a9a25-d4ca366d-fda77985"))))
(let $17 '('"column0" '"column1" '"column2" '"column3"))
(let $18 (DqCnResult (TDqOutput $16 '0) $17))
(let $19 (KqpPhysicalTx '($14 $16) '($18) '() $12))
(let $20 (PgType 'bytea))
(let $21 (PgType 'text))
(let $22 '('"column1" $21))
(let $23 (KqpTxResultBinding (ListType (StructType '('"column0" $20) $22 '('"column2" $20) '('"column3" (PgType 'json)) '('"column4" (PgType 'jsonb)))) '0 '0))
(let $24 (KqpTxResultBinding (ListType (StructType '('"column0" $21) $22 '('"column2" $21) '('"column3" (PgType 'uuid)))) '1 '0))
(return (KqpPhysicalQuery '($13 $19) '($23 $24) '('('"type" '"query"))))
)
