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