dropStreamGraph

语法

dropStreamGraph(name, [includeTables])

参数

name 字符串标量，表示流图的名字。可以传入完整的流图全限定名（如 catalog_name.orca_graph.graph_name），也可以仅提供流图名（如 factors）；系统会根据当前的 catalog 设置自动补全为对应的全限定名。

includesTables 可选参数，布尔值，表示在删除流图时是否同时删除该流图中用户显式创建的流表（如 source、sink 等），默认为 false。

详情

销毁指定流图。销毁成功后，流图状态转为 destroyed，但流图记录不会被删除。

  • 如果 includesTables=true，则在删除流图的同时，也会删除该流图中用户显式创建的流表（如 source、sink 等）。必须保证该流图中的流表未被其它流图引用。可通过 getStreamTableMeta 查看流流表的引用情况。
  • 否则，仅删除流图本身，不会影响这些流表。

在集群部署模式下，执行该操作的用户必须是管理员用户或拥有流图创建时所用计算组的 COMPUTE_GROUP_EXEC 权限。若在单节点部署环境中使用，则无需进行权限校验。

例子

dropStreamGraph("demo.orca_graph.indicators")

getStreamGraphMeta("demo.orca_graph.indicators")["status"]
// Output: ["destroyed"]

相关函数：createStreamGraph, StreamGraph::dropGraph