stream - 如何使用流但仍然保留数据而不进行偏移

Question

我们需要在第一个事务使用数据后将数据保留在流中。我们如何做到这一点？第二笔交易将再次消费并抵消流。需要第二个 DML 的解决方案，以便在第一个 DML 完成后查看流数据。两个 DML 都需要流中的相同数据。

Answer 1

Sergiu 的评论将是更受欢迎的选择，但另一种方法可能是首先使用简单的 SELECT 语句查询流，然后根据最后的查询结果使用 DML 语句进行跟进

SELECT * FROM my_stream;


INSERT INTO my_table select * from table(result_scan(last_query_id()));