dropOrcaStreamTable

First introduced in version: 3.00.4

Syntax

dropOrcaStreamTable(name)

Details

Deletes an Orca stream table.

The table can only be deleted if it is no longer referenced by any stream graph. You can use getOrcaStreamTableMeta to check its references.

Note:

Before calling this function, you must first enable the Orca feature by setting enableORCA=true in the configuration file cluster.cfg or controller.cfg.

Parameters

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

Returns

None.

Examples

// Create an Orca stream table
if(!existsCatalog("demo")){
    createCatalog("demo")
}
go
use catalog demo

createOrcaStreamTable("trade", `time`symbol`price`volume, [DATETIME,SYMBOL,DOUBLE,LONG])

// Delete the Orca stream table
dropOrcaStreamTable("demo.orca_table.trade")
// or dropOrcaStreamTable("trade")