getTopicProcessedOffset
Syntax
getTopicProcessedOffset(topic)
Arguments
topic is the subscription topic returned by function subscribeTable
Details
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.
Examples
$ 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;
time |
sym |
qty |
---|---|---|
2018.10.08T01:01:01.002 |
A |
1 |
2018.10.08T01:01:01.003 |
B |
1 |
2018.10.08T01:01:01.004 |
A |
1 |
2018.10.08T01:01:01.005 |
B |
1 |
2018.10.08T01:01:01.006 |
A |
1 |
2018.10.08T01:01:01.007 |
B |
1 |
$ getTopicProcessedOffset(topic);
5