流计算示例的疑问

流计算下面这个示例不太懂,为什么刚建完的临时表马上就释放了?

tradeOriginalStreamTemp = streamTable(1000000:0, colName, colType)
try{ enableTableShareAndPersistence(table=tradeOriginalStreamTemp, tableName="tradeOriginalStream", asynWrite=true, compress=true, cacheSize=1000000, retentionMinutes=1440, flushMode=0, preCache=10000) } catch(ex){ print(ex) }
undef("tradeOriginalStreamTemp")


代码摘自streaming_capital_flow_order_by_order.md · 浙江智臾科技有限公司/Tutorials_CN - Gitee.com 第3.4节 清理环境并创建相关流数据表

attachments-2024-02-8jvU17XC65d5714bf0029.png

请先 登录 后评论

1 个回答

wale

enableTableShareAndPersistence将表tradeOriginalStreamTemp 共享到当前节点的所有会话中,共享名为tradeOriginalStream。共享后,在其他会话中可访问tradeOriginalStream,但不能访问tradeOriginalStreamTemp ,所以这里就可以把tradeOriginalStreamTemp 释放了。


请先 登录 后评论