Create input and local streams.
The example creates an input stream named TradeStream and a local stream named TradeLocalStream. The local stream uses SELECT all (*) syntax to retrieve all data columns from TradeStream.
CREATE LOCAL STREAM TradeLocalStream SCHEMA (Ts BIGDATETIME, Symbol STRING, Price MONEY(2), Volume INTEGER) AS SELECT * from TradeStream;
ATTACH INPUT ADAPTER csvInConn1 TYPE dsv_in TO TradeStream PROPERTIES blockSize=1, dateFormat='%Y/%m/%d %H:%M:%S', delimiter=',', dir='../exampledata', expectStreamNameOpcode=false, fieldCount=0, file='stock-trades.csv', filePattern='*.csv', hasHeader=true, safeOps=false, skipDels=false, timestampFormat= '%Y/%m/%d %H:%M:%S';
The example attaches the File CSV Input adapter to TradeStream, then creates an output stream named TradeOutStream.
CREATE OUTPUT STREAM TradeOutStream AS SELECT * FROM TradeLocalStream ;
TradeOutStream retrieves all the data columns from TradeLocalStream using SELECT all syntax, and outputs them using the File CSV Output adapter.
ATTACH OUTPUT ADAPTER Adapter1 TYPE dsv_out TO TradeOutStream PROPERTIES dir = '../output' , file = 'streams.csv' , outputBase = TRUE , hasHeader = TRUE ;