enableTableShareAndPersistence将表tradeOriginalStreamTemp 共享到当前节点的所有会话中,共享名为tradeOriginalStream。共享后,在其他会话中可访问tradeOriginalStream,但不能访问tradeOriginalStreamTemp ,所以这里就可以把tradeOriginalStreamTemp 释放了。
流计算下面这个示例不太懂,为什么刚建完的临时表马上就释放了?
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节 清理环境并创建相关流数据表