发布端会在队列中过滤,过滤后的数据通过tcp发给订阅者。
多个 subScribeTable 订阅同一个表 stream_tb ,已经设置了 setStreamTableFilterColumn 和 filter ,订阅分别处理不同的数据;
在数据 append 到 stream_tb 的时候,使用 getStreamingStat 函数发现,pubTables 中各个 actions 的 msgOffset 的依次增加的;
是否说明,数据 append 到 stream_tb 后,数据是分别全量灌给不同的 subscribe ,然后不同的 subscribe 再自行处理数据过滤?