getTopicProcessedOffset

语法

getTopicProcessedOffset(topic)

参数

topicsubscribeTable 函数返回的订阅主题。

详情

如果subscribeTable函数的persistOffset参数为true,那么该函数返回最新一条已经处理的订阅数据的偏移量;如果subscribeTable函数的persistOffset参数为false,那么该函数返回-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;

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