Page Comparison

...

• Receives events through the buildStatisticsStream.
• Adds events that satisfy the condition isBuildFailed == true to a cron window. The cron window is configured to output at 1 am every day using the cron notation.
• Selects the attributes project, productTeam, lastCommitter, count(timeStamp) as totalBuildFailures.
• The group by clause causes the count() to be calculated per project.
• Outputs events to the buildFailureStream.

Prerequisites

See Prerequisites in CEP Samples Setup page.

...

• Points the default Axis2 repo to <CEP_HOME>/samplesamples/cep/artifacts/0115 (by default, the Axis2 repo is <CEP_HOME>/repository/deployment/server).

...

1. Open another terminal, go to <CEP_HOME>/samples/cep/producers/http and run the following command:

   ant -Durl=http://localhost:9763/endpoints/buildStatisticsEventReceiver -Dsn=0115

   It builds the http client and publishes the events at  <CEP_HOME>/samples/cep/artifacts/0115/buildStatisticsEvents.txt to the buildStatisticsEventReceiver http endpoint.

2. You can see the events getting received by CEP by the logs in its console. 
   Image Added

from buildStatisticsStream[isBuildFailed == true]#window.cron("0 5 * * * ?")
select project, productTeam, lastCommitter, count(timeStamp) as totalBuildFailures
group by project
insert into buildFailureStream;