createStreamGraph
语法
createStreamGraph(name)
参数
name 字符串标量,表示流图的名字。可以传入完整的流图全限定名(如 catalog_name.orca_graph.graph_name),也可以仅提供流图名(如 factors);系统会根据当前的 catalog 设置自动补全为对应的全限定名。
详情
创建一个声明式流图,支持以下功能:
- 控制流图的生命周期(如初始化、运行、销毁);
- 配置订阅与私有流表的行为;
- 定义数据源(如持久化流表、高可用流数据表、流计算引擎等)。
返回值:StreamGraph 对象。
例子
创建一个名为 indicators 的流图。
if (!existsCatalog("orca")) {
createCatalog("orca")
}
go
use catalog orca
g = createStreamGraph("indicators")