Debugging and Running an Application in Linux

After the preparation in Linux Environment is complete, enter the following CQL statements in the CQL command line interface of the Linux client:

>CREATE INPUT STREAM s
>    (id INT, name STRING, type INT)
> SOURCE randomgen
>           PROPERTIES
>           ( "timeUnit" = "SECONDS", "period" = "1",
>           "eventNumPerPeriod" = "1", "isSchedule" = "true");
Streaming>
>CREATE OUTPUT STREAM rs
>(type INT, cc INT)
> SINK ConsoleOutput;
Streaming>
>INSERT INTO STREAM rs SELECT type, count(id) as cc FROM s[RANGE 20 SECONDS BATCH] WHERE id > 5 GROUP BY type;
Streaming>
>SUBMIT APPLICATION example;
Streaming>show applications;

Figure 1 shows the running results.

Figure 1 Running result