Closed
Description
Query:
CREATE sink nexmark_q1
AS
SELECT
auction,
bidder,
0.908 * price as price,
date_time
FROM bid with ( connector = 'blackhole', format = 'append_only' );
Plan:
StreamSink { type: append-only, columns: [auction, bidder, price, date_time] }
└─StreamProject { exprs: [$expr1, $expr2, $expr3, $expr4] }
└─StreamProject { exprs: [Field(bid, 0:Int32) as $expr1, Field(bid, 1:Int32) as $expr2, (0.908:Decimal * Field(bid, 2:Int32)) as $expr3, Field(bid, 5:Int32) as $expr4, _row_id] }
└─StreamFilter { predicate: (event_type = 2:Int32) }
└─StreamRowIdGen { row_id_index: 4 }
└─StreamSource { source: "nexmark", columns: ["event_type", "person", "auction", "bid", "_row_id"] }
(6 rows)
two consecutive StreamProjects 🤔
Originally posted by @lmatz in #7353 (comment)
Metadata
Metadata
Assignees
Labels
No labels