(
(let $1 (DataType 'String))
(let $2 '('"key" $1))
(let $3 '('('"_logical_id" '1678) '('"_id" '"6b2b9689-4ff7aaa8-25e06fbd-fadbbdcd") '('"_wide_channels" (StructType '('_yql_agg_0 $1) $2))))
(let $4 (DqPhyStage '() (lambda '() (block '(
  (let $13 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $14 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $13)))
  (let $15 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('HasRLS '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $16 (YtStat '('Id '"Input") '('RecordsCount '"4") '('DataSize '"166") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $17 (YtTable '"Input" $14 $15 $16 '() (Void) (Void) '"/Root/plato"))
  (let $18 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $17 '('"key" '"value") (Void) (Void) (Void))) '()))))
  (let $19 (lambda '($29 $30) $30 $29))
  (return (FromFlow (DqPhyHashCombine (DqReadWideWrap $18 '()) '-1073741824 (lambda '($20 $21) $20) (lambda '($22 $23 $24) $24) (lambda '($25 $26 $27 $28) (AggrMax $27 $28)) $19)))
))) $3))
(let $5 (DqCnHashShuffle (TDqOutput $4 '0) '('1) '0 '"HashV2"))
(let $6 '('('"_logical_id" '1761) '('"_id" '"2e787d2c-9226f7e5-b6f5639b-d7456d85") '('"_partition_mode" '"aggregate")))
(let $7 (DqPhyStage '($5) (lambda '($31) (block '(
  (let $32 (NarrowSqueezeToDict (ToFlow $31) (lambda '($38 $39) $39) (lambda '($40 $41) (AsStruct '('_yql_agg_0 $40) '('"key" $41))) '('Auto 'Many)))
  (let $33 (lambda '($44) (Member $44 '_yql_agg_0) (Member $44 '"key")))
  (let $34 (lambda '($45 $46) $45 $46))
  (let $35 (lambda '($51 $52 $53 $54) (AggrMax $51 $53) $54))
  (let $36 (WideCondense1 (ExpandMap (OrderedFlatMap $32 (lambda '($42) (OrderedFlatMap (DictPayloads $42) (lambda '($43) $43)))) $33) $34 (lambda '($47 $48 $49 $50) (AggrNotEquals $48 $50)) $35))
  (let $37 (lambda '($55 $56) $56 $55 (== $55 (String '"FOO"))))
  (return (FromFlow (NarrowMap (WideFilter (WideMap $36 $37) (lambda '($57 $58 $59) $59)) (lambda '($60 $61 $62) (AsStruct '('"key" $60) '('"subkey" (String '"WAT")) '('"value" $61))))))
))) $6))
(let $8 (DqCnUnionAll (TDqOutput $7 '0)))
(let $9 (DqPhyStage '($8) (lambda '($63) $63) '('('"_logical_id" '2107) '('"_id" '"a5aa07a1-4e73d993-ca6c9a13-a0d0a708"))))
(let $10 '($4 $7 $9))
(let $11 '('"key" '"subkey" '"value"))
(let $12 (DqCnResult (TDqOutput $9 '0) $11))
(return (KqpPhysicalQuery '((KqpPhysicalTx $10 '($12) '() '('('"type" '"generic")))) '((KqpTxResultBinding (ListType (StructType $2 '('"subkey" $1) '('"value" $1))) '0 '0)) '('('"type" '"query"))))
)
