流表持久化，table must be a local(not shared) realtime (stream) table.

colName=["time","x"]
colType=["timestamp","int"]
share streamTable(100:0, colName, colType) as t;
enableTableShareAndPersistence(table=t, tableName=`st, cacheSize=1200000)

我这里是想对流表做持久化操作，但是报出异常

table must be a local(not shared) realtime (stream) table.

0 条评论

默认排序时间排序

1 个回答

Yingnan Wang 2022-05-11 16:37

原因是"t"这个对象已经是一个共享流表，enableTableShareAndPersistence函数是对普通流表进行共享和持久化。

可以参考如下脚本进行共享和持久化

colName=["time","x"]
colType=["timestamp","int"]
t=streamTable(100:0, colName, colType);
enableTableShareAndPersistence(table=t, tableName=`st, cacheSize=1200000)

当然对已共享流表进行持久化可以使用enableTablePersistence函数。

我们推荐使用 enableTableShareAndPersistence 函数将共享和持久化组织成原子性操作。

流表持久化，table must be a local(not shared) realtime (stream) table.

1 个回答

相似问题