ADAPTER START GROUPS Statement

The example creates schemas named TradeSchema, CompanySchema, and JoinSchema inherits its schema from TradeSchema. The text in parentheses tells the project server to extend TradeSchema by adding another column named Company.

Create Schema JoinSchema
	inherits TradeSchema (Company String);

The example creates an input window named TradeWindow that references TradeSchema, and another input window named CompanyInfo that references CompanySchema. An output join window that uses the structure defined in JoinSchema is created to join the TradeWindow and CompanyInfo input windows using their symbol and timestamp values.

CREATE OUTPUT WINDOW Join1 
			SCHEMA JoinSchema Primary Key deduced 
 			AS 
			SELECT t.Ts as Ts, c.StockSymbol as Symbol , 
       t.Price as Price , t.Volume as Volume, c.Company as Company
 			FROM TradeWindow t  join CompanyInfo c
  		on t.Symbol = c.StockSymbol
  		group by t.Ts
  		;

The example attaches a File CSV Input adapter named csvTradesIn2 to TradeWindow, and another File CSV Input adapter named csvCompanyIn to CompanyInfo. The adapter instance named csvTradesIn2 is assigned to RunGroup0, and the adapter instance named csvCompanyIn is assigned to RunGroup1.

The ADAPTER START GROUPS statement uses these adapter group assignments when specifying the order in which adapters start. In this example, the project server starts RunGroup1 adapters first, followed by RunGroup0 adapters.

ADAPTER START GROUPS RunGroup1, RunGroup0 ;