getTopicProcessedOffset

getTopicProcessedOffset(topic)

topic is the subscription topic returned by function subscribeTable

If parameter persistOffset of function subscribeTable is true, return the offset of the last subscribed message that has been processed.

If parameter persistOffset of function subscribeTable is false, return -1.

share streamTable(1000:0, `time`sym`qty, [TIMESTAMP, SYMBOL, INT]) as trades
trades_1 = streamTable(1000:0, `time`sym`qty, [TIMESTAMP, SYMBOL, INT])
topic=subscribeTable(tableName="trades", actionName="trades_1", offset=0, handler=append!{trades_1}, msgAsTable=true, persistOffset=true)
def writeData(n){
   timev = 2018.10.08T01:01:01.001 + timestamp(1..n)
   symv =take(`A`B, n)
   qtyv = take(1, n)
   insert into trades values(timev, symv, qtyv)
}
writeData(6);
select * from trades_1;

getTopicProcessedOffset(topic);
// output
5