setStreamTableFilterColumn

语法

setStreamTableFilterColumn(streamTable, columnName)

参数

streamTable 是流数据表。

columnName 是一个字符串。

详情

指定流数据表的过滤列。该函数需要配合 subscribeTable 函数的 filter 参数一起使用。filter 是一个向量,streamTablecolumnName 列在 filter 中的数据才会发布到订阅端,不在 filter 中的数据不会发布。一个流数据表只能指定一个过滤列。

例子

下例中,指定了流数据表 trades 的 symbol 列为过滤列,同一节点上的表 trades_slave 订阅流数据表 trades 时把 filter 设置为 ["IBM", "GOOG"],即流数据表 trades 的 symbol 为 "IBM" 或 "GOOG" 时才会发布到订阅端。

share streamTable(10000:0,`time`symbol`price, [TIMESTAMP,SYMBOL,INT]) as trades
setStreamTableFilterColumn(trades, `symbol)
trades_1=table(10000:0,`time`symbol`price, [TIMESTAMP,SYMBOL,INT])

filter=symbol(`IBM`GOOG)

subscribeTable(tableName=`trades, actionName=`trades_1, handler=append!{trades_1}, msgAsTable=true, filter=filter);