Create left, right, and full joins between input windows.
The example creates two schemas named StocksSchema and OptionsSchema. It then creates an input window named InStocks that references StocksSchema, and another input window named InOptions that references OptionsSchema.
The example creates an output window named OutStockOptionFOJ that creates a full join between InStocks and InOptions using their timestamp values.
CREATE OUTPUT WINDOW OutStockOptionFOJ
PRIMARY KEY (Ts)
AS
SELECT InStocks.Ts Ts , InStocks.Symbol Symbol , InStocks.Price StockPrice ,
InStocks.Volume StockVolume , InOptions.StockSymbol OptionStockSymbol ,
InOptions.OptionSymbol OptionSymbol , InOptions.Price OptionPrice,
InOptions.Volume OptionVolume
FROM InStocks FULL JOIN InOptions
ON
InStocks.Ts = InOptions.Ts;
The example creates an output window named OutStockOptionLOJ that creates a left outer join between InStocks and InOptions using their timestamp values.
CREATE OUTPUT WINDOW OutStockOptionLOJ
Primary Key (Ts)
AS
SELECT InStocks.Ts Ts , InStocks.Symbol Symbol ,
InStocks.Price StockPrice , InStocks.Volume StockVolume ,
InOptions.StockSymbol OptionStockSymbol ,
InOptions.OptionSymbol OptionSymbol , InOptions.Price OptionPrice,
InOptions.Volume OptionVolume
FROM InStocks JOIN InOptions
ON
InStocks.Ts = InOptions.Ts ;
Primary Key (Ts)
AS
SELECT InStocks.Ts Ts , InStocks.Symbol Symbol ,
InStocks.Price StockPrice , InStocks.Volume StockVolume ,
InOptions.StockSymbol OptionStockSymbol ,
InOptions.OptionSymbol OptionSymbol , InOptions.Price OptionPrice,
InOptions.Volume OptionVolume
FROM InStocks JOIN InOptions
on
InStocks.Ts = InOptions.Ts ;
The example creates an output window named OutStockOptionROJ that creates a right outer join between InStocks and InOptions using their timestamp values.
CREATE OUTPUT WINDOW OutStockOptionROJ
PRIMARY KEY (Ts)
AS
SELECT InOptions.Ts Ts , InStocks.Symbol Symbol ,
InStocks.Price StockPrice , InStocks.Volume StockVolume ,
InOptions.StockSymbol OptionStockSymbol ,
InOptions.OptionSymbol OptionSymbol , InOptions.Price OptionPrice,
InOptions.Volume OptionVolume
FROM InStocks RIGHT JOIN InOptions
on
InStocks.Ts = InOptions.Ts ;
The example attaches a File CSV Input adapter named csvInStocks to InStocks, and a File CSV Input adapter named csvInOptions to InOptions.