(
(let $1 (DataSource '"yt" '"/Root/plato"))
(let $2 '('NativeYtTypeFlags '0))
(let $3 '('StrictSchema '1))
(let $4 '('UniqueKeys '0))
(let $5 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0)))
(let $6 '('RecordsCount '1))
(let $7 '('DataSize '"40"))
(let $8 '('ChunkCount '1))
(let $9 '('ModifyTime '0))
(let $10 '('Revision '0))
(let $11 '('"key" '"subkey" '"value"))
(let $12 (DqPhyStage '() (lambda '() (block '(
  (let $66 '@@["StructType";[["key";["OptionalType";["DataType";"String"]]];["subkey";["OptionalType";["DataType";"String"]]];["value";["OptionalType";["DataType";"String"]]]]]@@)
  (let $67 (YqlRowSpec $2 $3 $4 '('Type $66)))
  (let $68 (YtStat '('Id '"Input1") $6 $7 $8 $9 $10))
  (let $69 (YtTable '"Input1" $67 $5 $68 '() (Void) (Void) '"/Root/plato"))
  (let $70 (YtReadTable! world $1 '((YtSection '((YtPath $69 $11 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $70 '()) (lambda '($71 $72 $73) (AsStruct '('"key" $71) '('"subkey" $72) '('"value" $73))))))
))) '('('"_logical_id" '4292) '('"_id" '"b924a302-f95e7ec3-e52b538d-9169a42b"))))
(let $13 (DqCnUnionAll (TDqOutput $12 '0)))
(let $14 (DqPhyStage '($13) (lambda '($74) $74) '('('"_logical_id" '4582) '('"_id" '"d166059a-27083fe8-a784926f-39671219"))))
(let $15 (DqCnResult (TDqOutput $14 '0) $11))
(let $16 '('('"type" '"generic")))
(let $17 (KqpPhysicalTx '($12 $14) '($15) '() $16))
(let $18 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
(let $19 '('Type $18))
(let $20 (Bool 'true))
(let $21 '('SortDirections '($20 $20)))
(let $22 (DataType 'String))
(let $23 '('SortedByTypes '($22 $22)))
(let $24 '('('"unordered")))
(let $25 (lambda '($80 $81 $82) (AsStruct '('"key" $80) '('"subkey" $81) '('"value" $82))))
(let $26 (DqPhyStage '() (lambda '() (block '(
  (let $75 '('"key" '"subkey"))
  (let $76 (YqlRowSpec $2 $3 $4 $19 $21 '('SortMembers $75) '('SortedBy $75) $23))
  (let $77 (YtStat '('Id '"Input2") $6 $7 $8 $9 $10))
  (let $78 (YtTable '"Input2" $76 $5 $77 '() (Void) (Void) '"/Root/plato"))
  (let $79 (YtReadTable! world $1 '((YtSection '((YtPath $78 $11 (Void) (Void))) $24))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $79 '()) $25)))
))) '('('"_logical_id" '4334) '('"_id" '"11e2fada-7561ca59-479fa35a-43771527"))))
(let $27 (DqCnUnionAll (TDqOutput $26 '0)))
(let $28 (DqPhyStage '($27) (lambda '($83) $83) '('('"_logical_id" '4689) '('"_id" '"6e98dfda-ed698c80-23c0b414-6a53dfa6"))))
(let $29 (DqCnResult (TDqOutput $28 '0) $11))
(let $30 (KqpPhysicalTx '($26 $28) '($29) '() $16))
(let $31 '('"key"))
(let $32 '('SortMembers $31))
(let $33 '('SortedByTypes '($22)))
(let $34 (DqPhyStage '() (lambda '() (block '(
  (let $84 (YqlRowSpec $2 $3 $4 $19 '('SortDirections '($20)) $32 '('SortedBy $31) $33))
  (let $85 (YtStat '('Id '"Input3") $6 $7 $8 $9 $10))
  (let $86 (YtTable '"Input3" $84 $5 $85 '() (Void) (Void) '"/Root/plato"))
  (let $87 (YtReadTable! world $1 '((YtSection '((YtPath $86 $11 (Void) (Void))) $24))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $87 '()) $25)))
))) '('('"_logical_id" '4376) '('"_id" '"c32cb5f7-a9808ddc-86fe8d56-ef120a36"))))
(let $35 (DqCnUnionAll (TDqOutput $34 '0)))
(let $36 (DqPhyStage '($35) (lambda '($88) $88) '('('"_logical_id" '4795) '('"_id" '"605a4d0b-bf4823fe-5e9ddf18-2719e38d"))))
(let $37 (DqCnResult (TDqOutput $36 '0) $11))
(let $38 (KqpPhysicalTx '($34 $36) '($37) '() $16))
(let $39 (DqPhyStage '() (lambda '() (block '(
  (let $89 (YqlRowSpec $2 $3 $4 $19 '('SortDirections '((Bool 'false))) $32 '('SortedBy '('"_yql_column_0")) $33))
  (let $90 (YtStat '('Id '"Input4") $6 '('DataSize '"133") $8 $9 $10))
  (let $91 (YtTable '"Input4" $89 $5 $90 '() (Void) (Void) '"/Root/plato"))
  (let $92 (YtReadTable! world $1 '((YtSection '((YtPath $91 $11 (Void) (Void))) $24))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $92 '()) $25)))
))) '('('"_logical_id" '4418) '('"_id" '"bc1fbf61-75e05346-1c24ff3c-8cbbc62a"))))
(let $40 (DqCnUnionAll (TDqOutput $39 '0)))
(let $41 (DqPhyStage '($40) (lambda '($93) $93) '('('"_logical_id" '4891) '('"_id" '"ad221033-2fefd59d-83c8bfc5-d4f7bc89"))))
(let $42 (DqCnResult (TDqOutput $41 '0) $11))
(let $43 (KqpPhysicalTx '($39 $41) '($42) '() $16))
(let $44 '('"any_column" '"boolean_column" '"date_column" '"double_column" '"int64_column" '"interval_column" '"list_column" '"null_column" '"optional_column" '"string_column"))
(let $45 (DqPhyStage '() (lambda '() (block '(
  (let $94 '@@["StructType";[["any_column";["OptionalType";["DataType";"Yson"]]];["boolean_column";["DataType";"Bool"]];["date_column";["DataType";"Date"]];["double_column";["DataType";"Double"]];["int64_column";["DataType";"Int64"]];["interval_column";["DataType";"Interval"]];["list_column";["ListType";["DataType";"Bool"]]];["null_column";["NullType"]];["optional_column";["OptionalType";["DataType";"Utf8"]]];["string_column";["DataType";"String"]]]]@@)
  (let $95 (YqlRowSpec $2 $3 $4 '('Type $94)))
  (let $96 (YtStat '('Id '"Input5") $6 '('DataSize '"264") $8 $9 $10))
  (let $97 (YtTable '"Input5" $95 $5 $96 '() (Void) (Void) '"/Root/plato"))
  (let $98 (YtReadTable! world $1 '((YtSection '((YtPath $97 $44 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $98 '()) (lambda '($99 $100 $101 $102 $103 $104 $105 $106 $107 $108) (AsStruct '('"any_column" $99) '('"boolean_column" $100) '('"date_column" $101) '('"double_column" $102) '('"int64_column" $103) '('"interval_column" $104) '('"list_column" $105) '('"null_column" $106) '('"optional_column" $107) '('"string_column" $108))))))
))) '('('"_logical_id" '4481) '('"_id" '"a55f24c2-1a18faa5-1cad10b4-fe0fbe53"))))
(let $46 (DqCnUnionAll (TDqOutput $45 '0)))
(let $47 (DqPhyStage '($46) (lambda '($109) $109) '('('"_logical_id" '4987) '('"_id" '"4a5d28a8-5fab9501-402ec53a-7778e044"))))
(let $48 (DqCnResult (TDqOutput $47 '0) $44))
(let $49 (KqpPhysicalTx '($45 $47) '($48) '() $16))
(let $50 (DqPhyStage '() (lambda '() (block '(
  (let $110 (YqlRowSpec $2 $3 $4 $19 $21 '('SortedBy '('"_yql_column_0" '"key")) $23))
  (let $111 (YtStat '('Id '"Input6") $6 '('DataSize '"65") $8 $9 $10))
  (let $112 (YtTable '"Input6" $110 $5 $111 '() (Void) (Void) '"/Root/plato"))
  (let $113 (YtReadTable! world $1 '((YtSection '((YtPath $112 $11 (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $113 '()) $25)))
))) '('('"_logical_id" '4537) '('"_id" '"610cb52-1a181e3c-64e6a2b0-e66c3ab"))))
(let $51 (DqCnUnionAll (TDqOutput $50 '0)))
(let $52 (DqPhyStage '($51) (lambda '($114) $114) '('('"_logical_id" '5107) '('"_id" '"a69adf05-c8c98275-cb57651f-eff7d716"))))
(let $53 (DqCnResult (TDqOutput $52 '0) $11))
(let $54 (KqpPhysicalTx '($50 $52) '($53) '() $16))
(let $55 '($17 $30 $38 $43 $49 $54))
(let $56 (OptionalType $22))
(let $57 (KqpTxResultBinding (ListType (StructType '('"key" $56) '('"subkey" $56) '('"value" $56))) '0 '0))
(let $58 (ListType (StructType '('"key" $22) '('"subkey" $22) '('"value" $22))))
(let $59 (KqpTxResultBinding $58 '1 '0))
(let $60 (KqpTxResultBinding $58 '"2" '0))
(let $61 (KqpTxResultBinding $58 '"3" '0))
(let $62 (DataType 'Bool))
(let $63 (KqpTxResultBinding (ListType (StructType '('"any_column" (OptionalType (DataType 'Yson))) '('"boolean_column" $62) '('"date_column" (DataType 'Date)) '('"double_column" (DataType 'Double)) '('"int64_column" (DataType 'Int64)) '('"interval_column" (DataType 'Interval)) '('"list_column" (ListType $62)) '('"null_column" (NullType)) '('"optional_column" (OptionalType (DataType 'Utf8))) '('"string_column" $22))) '"4" '0))
(let $64 (KqpTxResultBinding $58 '"5" '0))
(let $65 '($57 $59 $60 $61 $63 $64))
(return (KqpPhysicalQuery $55 $65 '('('"type" '"query"))))
)
