appendOrcaStreamTable

appendOrcaStreamTable(name, data)

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.

data is a table object containing the data to be inserted.

Appends data to an orca stream table.

Note: This function does not support regular (non-Orca) stream tables.

Insert the snapshot table into an orca stream table.

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

t = table(1..100 as id, 1..100 as value, take(09:29:00.000..13:00:00.000, 100) as timestamp)
g = createStreamGraph("factor")
baseStream = g.source("snapshot",  1024:0, schema(t).colDefs.name, schema(t).colDefs.typeString)
  .reactiveStateEngine([<cumsum(value)>, <timestamp>])
  .setEngineName("rse")
  .buffer("end")
  
g.submit()

appendOrcaStreamTable("snapshot", t)

We can verify the inserted data with a SQL query like SELECT * FROM <catalog>.orca_table.<name>. The <catalog> part is optional—if omitted, the system will use the current catalog automatically.

select * from orca_table.end