(
(declare %kqp%current_utc_timestamp (DataType 'Timestamp))
(declare %kqp%random_number (DataType 'Uint64))
(let $1 '"%kqp%random_number")
(let $2 (DataType 'Uint64))
(let $3 '('"_partition_mode" '"single"))
(let $4 '('('"_logical_id" '2041) '('"_id" '"873151a-689115-7b8cfe6-89c7000a") $3))
(let $5 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"column0" (Uint64 '"1778399084363005603")) '('"column1" %kqp%random_number))))) $4))
(let $6 '('"column0" '"column1"))
(let $7 (DqCnResult (TDqOutput $5 '0) $6))
(let $8 '('('"type" '"generic")))
(let $9 (KqpPhysicalTx '($5) '($7) '('($1 (KqpTxInternalBinding $2 '"RandomNumber"))) $8))
(let $10 (DqPhyStage '() (lambda '() (block '(
  (let $54 '@@["StructType";[["key";["DataType";"String"]];["subkey";["DataType";"String"]];["value";["DataType";"String"]]]]@@)
  (let $55 (YqlRowSpec '('NativeYtTypeFlags '0) '('StrictSchema '1) '('UniqueKeys '0) '('Type $54)))
  (let $56 (YtMeta '('CanWrite '1) '('DoesExist '1) '('YqlCompatibleScheme '1) '('InferredScheme '0) '('IsDynamic '0) '('Attrs '('('"native_strict_schema" '"false")))))
  (let $57 (YtStat '('Id '"Input") '('RecordsCount '4) '('DataSize '"166") '('ChunkCount '1) '('ModifyTime '0) '('Revision '0)))
  (let $58 (YtTable '"Input" $55 $56 $57 '() (Void) (Void) '"/Root/plato"))
  (let $59 (YtReadTable! world (DataSource '"yt" '"/Root/plato") '((YtSection '((YtPath $58 '('"key") (Void) (Void))) '()))))
  (return (FromFlow (NarrowMap (DqReadWideWrap $59 '()) (lambda '($60) (AsStruct '('"date" (String '"2025-10-24")) '('"key" $60))))))
))) '('('"_logical_id" '2111) '('"_id" '"f6c6ebbd-705d283d-8f6b2d5c-4fc3fc0a"))))
(let $11 (DqCnUnionAll (TDqOutput $10 '0)))
(let $12 (DqPhyStage '($11) (lambda '($61) $61) '('('"_logical_id" '2377) '('"_id" '"fde27cd2-4a694f89-51ea575d-77ea09b4"))))
(let $13 (DqCnResult (TDqOutput $12 '0) '('"key" '"date")))
(let $14 (KqpPhysicalTx '($10 $12) '($13) '() $8))
(let $15 '('('"_logical_id" '2135) '('"_id" '"c493ad9-1356f66c-638f4962-965b0a67") $3))
(let $16 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"column0" (String '"foobar")))))) $15))
(let $17 '('"column0"))
(let $18 (DqCnResult (TDqOutput $16 '0) $17))
(let $19 (KqpPhysicalTx '($16) '($18) '() $8))
(let $20 '"%kqp%current_utc_timestamp")
(let $21 (DataType 'Timestamp))
(let $22 '('('"_logical_id" '2159) '('"_id" '"cf7aa33b-e77b5900-592d484a-46ecccbc") $3))
(let $23 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"column0" (Timestamp '"1761322846382776")) '('"column1" %kqp%current_utc_timestamp))))) $22))
(let $24 (DqCnResult (TDqOutput $23 '0) $6))
(let $25 (KqpPhysicalTx '($23) '($24) '('($20 (KqpTxInternalBinding $21 '"CurrentUtcTimestamp"))) $8))
(let $26 (DataType 'Bool))
(let $27 '('('"_logical_id" '2183) '('"_id" '"f0f4c44d-d586641a-b143bdab-25cb3fbb") $3))
(let $28 (DqPhyStage '() (lambda '() (block '(
  (let $62 (ResourceType '"Yson2.Node"))
  (let $63 '($62 '"" '1))
  (let $64 (CallableType '() '($26) $63 $63))
  (let $65 '('('"strict")))
  (let $66 (Udf '"Yson2.Equals" (Void) (VoidType) '"" $64 (VoidType) '"" $65))
  (let $67 (DataType 'Yson))
  (let $68 (TupleType (TupleType $67) (StructType) (TupleType)))
  (let $69 '($67 '"" '1))
  (let $70 (CallableType '('1) '($62) $69 '((OptionalType (ResourceType '"Yson2.Options")))))
  (let $71 (Udf '"Yson2.Parse" (Void) $68 '"" $70 (VoidType) '"" $65))
  (let $72 '"{\"a\"=7u;\"c\"=[<\"d\"=%true>1;#;\"\\xD0\\xBF\\xD1\\x80\\xD0\\xB8\\xD0\\xB2\\xD0\\xB5\\xD1\\x82\";-3.4]}")
  (let $73 (Apply $66 (Apply $71 (Yson $72)) (Apply $71 (Yson '"{a=7u;c=[<d=%true>1;#;\"\u043F\u0440\u0438\u0432\u0435\u0442\";-3.4]}"))))
  (return (Iterator (AsList (AsStruct '('"column0" $73)))))
))) $27))
(let $29 (DqCnResult (TDqOutput $28 '0) $17))
(let $30 (KqpPhysicalTx '($28) '($29) '() $8))
(let $31 '('('"_logical_id" '2207) '('"_id" '"eb60c860-a056284-3edbd99d-edc90427") $3))
(let $32 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"column0" (TzDate '"10956,Europe/Moscow")))))) $31))
(let $33 (DqCnResult (TDqOutput $32 '0) $17))
(let $34 (KqpPhysicalTx '($32) '($33) '() $8))
(let $35 '('('"_logical_id" '2231) '('"_id" '"823a9387-7b8a1d3d-ab336784-32d9b5f8") $3))
(let $36 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"column0" (TzDatetime '"946677723,Europe/Moscow")))))) $35))
(let $37 (DqCnResult (TDqOutput $36 '0) $17))
(let $38 (KqpPhysicalTx '($36) '($37) '() $8))
(let $39 '('('"_logical_id" '2255) '('"_id" '"df03ec87-363f77e4-2ed7b96a-68c3d194") $3))
(let $40 (DqPhyStage '() (lambda '() (Iterator (AsList (AsStruct '('"column0" (TzTimestamp '"946677723456789,Europe/Moscow")))))) $39))
(let $41 (DqCnResult (TDqOutput $40 '0) $17))
(let $42 (KqpPhysicalTx '($40) '($41) '() $8))
(let $43 '($9 $14 $19 $25 $30 $34 $38 $42))
(let $44 (KqpTxResultBinding (ListType (StructType '('"column0" $2) '('"column1" $2))) '0 '0))
(let $45 (DataType 'String))
(let $46 (KqpTxResultBinding (ListType (StructType '('"date" $45) '('"key" $45))) '1 '0))
(let $47 (KqpTxResultBinding (ListType (StructType '('"column0" $45))) '"2" '0))
(let $48 (KqpTxResultBinding (ListType (StructType '('"column0" $21) '('"column1" $21))) '"3" '0))
(let $49 (KqpTxResultBinding (ListType (StructType '('"column0" $26))) '4 '0))
(let $50 (KqpTxResultBinding (ListType (StructType '('"column0" (DataType 'TzDate)))) '"5" '0))
(let $51 (KqpTxResultBinding (ListType (StructType '('"column0" (DataType 'TzDatetime)))) '"6" '0))
(let $52 (KqpTxResultBinding (ListType (StructType '('"column0" (DataType 'TzTimestamp)))) '"7" '0))
(let $53 '($44 $46 $47 $48 $49 $50 $51 $52))
(return (KqpPhysicalQuery $43 $53 '('('"type" '"query"))))
)
