UnionStream with Stateful Store Migration

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;