createStreamGraph

createStreamGraph(name)

name is a string representing the name of the stream graph. You can provide either the fully qualified name (FQN), such as "catalog_name.orca_graph.graph_name", or just the graph name, like "factors". If only the name is given, the system will automatically complete it using the current catalog.

Creates a declarative stream graph. It supports the following capabilities:

• Lifecycle management: Initialize, execute, and terminate the stream graph.
• Configuration: Set parameters for subscriptions and private stream tables.
• Data source definition: Define sources including persisted stream tables, high-availability stream tables, and streaming engines.

Return value: A StreamGraph object.

Create a stream graph named “indicators”.

if (!existsCatalog("orca")) {
	createCatalog("orca")
}
go
use catalog orca

g = createStreamGraph("indicators") 

Related functions: dropStreamGraph, startStreamGraph, stopStreamGraph, StreamGraph::dropGraph