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.