useOrcaStreamTable

语法

useOrcaStreamTable(name, func, args...)

参数

name 表示流表的名称。字符串标量,可以传入完整的流表全限定名(如 trading.orca_graph.trades);也可以仅提供流表名(如 trades),系统会根据当前的 catalog 设置自动补全为对应的全限定名。

func 在流表所在节点上执行的函数,可以是内置函数或自定义函数。该函数必须至少包含一个参数,系统会将流表对象自动作为第一个参数传入。

args… 传递给 func 的其他参数,使用方式类似于远程过程调用函数 rpcargs… 参数。

详情

该函数通过 orca 流表名称定位其所在节点,并在该节点获取流表对象。随后将该流表作为首个参数传递给用户指定的函数 func 并执行。

该机制允许用户在本地代码中远程调用与操作流表相关的函数(如 replaygetStreamTableFilterColumn 等),无需手动管理节点和流表对象的绑定。

例子

通过 getStreamTableFilterColumn 函数查看 demo.orca_table.transaction 流表的过滤列:

useOrcaStreamTable("demo.orca_table.transaction", getStreamTableFilterColumn)