(
(let $1 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
(let $2 (Bool 'true))
(let $3 '('"key" '"subkey"))
(let $4 (DataType 'String))
(let $5 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $1) '('SortDirections '($2 $2)) '('SortMembers $3) '('SortedBy $3) '('SortedByTypes '($4 $4))))
(let $6 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
(let $7 (YtStat '('Id '"Input") '('RecordsCount '"4") '('DataSize '"166") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
(let $8 (YtTable '"Input" $5 $6 $7 '() (Void) (Void) '"/Root/plato"))
(let $9 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $8 $3 (Void) (Void))) '('('"unordered"))))))
(let $10 (DqReadWideWrap $9 '()))
(let $11 '('"_logical_id" '2339))
(let $12 '('"_wide_channels" (StructType '('"key" $4) '('"subkey" $4))))
(let $13 '($11 '('"_id" '"24067c0d-af7dad2e-8eb809a8-4eae2ccb") $12))
(let $14 (DqPhyStage '() (lambda '() (FromFlow (WideFilter $10 (lambda '($30 $31) (!= $31 (String '"bar")))))) $13))
(let $15 '($11 '('"_id" '"8322bc74-a2ca23ed-2568f55f-50a47e63") $12))
(let $16 (DqPhyStage '() (lambda '() (FromFlow (WideFilter $10 (lambda '($32 $33) (!= $33 (String '"foo")))))) $15))
(let $17 (DqCnMap (TDqOutput $14 '0)))
(let $18 (DqCnBroadcast (TDqOutput $16 '0)))
(let $19 '('0 '1))
(let $20 (StructType '('"key1" $4) '('"subkey1" $4)))
(let $21 '('('"_logical_id" '2474) '('"_id" '"52516768-4a2aca3-e478005c-2774f298") '('"_wide_channels" $20)))
(let $22 (DqPhyStage '($17 $18) (lambda '($34 $35) (block '(
  (let $36 '('Many 'Hashed 'Compact))
  (let $37 (NarrowSqueezeToDict (ToFlow $35) (lambda '($38 $39) '($38 $39)) (lambda '($40 $41) (AsStruct '('"key" $40) '('"subkey" $41))) $36))
  (return (FromFlow (FlatMap $37 (lambda '($42) (block '(
    (let $43 '('0 '0 '1 '1))
    (return (MapJoinCore (ToFlow $34) $42 'Inner $19 $3 $43 '() '('"a.key" '"a.subkey") '('"b.key" '"b.subkey")))
  ))))))
))) $21))
(let $23 (DqCnHashShuffle (TDqOutput $22 '0) $19 '0 '"HashV2"))
(let $24 '('('"_logical_id" '2520) '('"_id" '"94ed0913-52d51ebc-ad877203-3c0418fa") '('"_partition_mode" '"aggregate")))
(let $25 (DqPhyStage '($23) (lambda '($44) (block '(
  (let $45 (lambda '($48 $49) $48 $49))
  (let $46 (lambda '($50 $51 $52 $53)))
  (let $47 (WideCombiner (ToFlow $44) '"" $45 $46 $46 $45))
  (return (FromFlow (NarrowMap $47 (lambda '($54 $55) (AsStruct '('"key1" $54) '('"subkey1" $55))))))
))) $24))
(let $26 (DqCnUnionAll (TDqOutput $25 '0)))
(let $27 (DqPhyStage '($26) (lambda '($56) $56) '('('"_logical_id" '2937) '('"_id" '"31548ff5-f6564cef-60a19528-e6b96c3"))))
(let $28 '($14 $16 $22 $25 $27))
(let $29 (DqCnResult (TDqOutput $27 '0) '('"key1" '"subkey1")))
(return (KqpPhysicalQuery '((KqpPhysicalTx $28 '($29) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType $20) '0 '0)) '('('"type" '"query"))))
)
