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