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")