我使用函数
enableTableShareAndPersistence
现在我要统计流表的总行数,包括那些已经刷入磁盘的记录。
我从rwStream中调用exec count(*),但只得到流表内存中存储的记录数
尝试
getPersistenceMeta(rwStream)
totalSize