In this example, the Aleri UnionStream element has an attached stateful (memory) store and two input streams ("alldatatypes" and "alldatatypes1") that participate in a union operation. In CCL, the Aleri Store element migrates to a CREATE MEMORY STORE statement and the UnionStream element migrates to an output window with a UNION clause.
AleriML:
<Store file="store1" fullsize="64" id="store1" kind="memory"/> <UnionStream id="uniondatatypes" istream="alldatatypes alldatatypes1" store="store1"> </UnionStream>
CCL:
CREATE MEMORY STORE store1 PROPERTIES INDEXTYPE ='tree', INDEXSIZEHINT =8; CREATE OUTPUT WINDOW uniondatatypes SCHEMA (id INTEGER, a LONG, charData STRING) PRIMARY KEY (id, a) STORE store1 AS SELECT * FROM alldatatypes UNION SELECT * FROM alldatatypes1;