getOrcaStreamTaskSubscriptionMeta
Syntax
getOrcaStreamTaskSubscriptionMeta(name)
Arguments
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.
Details
Retrieve the subscription information of all streaming tasks in the specified streaming graph.
Return value: a table containing the following fields:
- taskId: Streaming task ID.
- tableName: Name of the streaming table.
- actionName: Name of the subscription task.
Examples
getOrcaStreamTaskSubscriptionMeta("streamGraph1") // name is the name of the streaming graph
getOrcaStreamTaskSubscriptionMeta("catalog1.orca_graph.streamGraph1") // name is the fully qualified name