Getting Started with CEP

Step 4: Running the data publisher

Open a terminal, go to <CEP_HOME>/samples/producers/pizza-shop and run the following command:

ant pizzaPublisherClient

Step 5: Adding an execution plan

1. In the Management Console, navigate to Home > Manage > Event Processor > Execution Plans.

2. Click on 'Add Execution Plan' 

3. This will show the 'Create new Execution Plan' window.

4. In the Execution Plan Name field, enter “pizaaOrderProcessingPlan”

5. There, under Query Expressions, import both deliveryStream:1.0.0 and orderStream:1.0.0.

To do this,

i. Go to Import Stream drop-down menu and select deliveryStream:1.0.0. In the As: text field, type deliveryStream and click Import.

ii. Go to Import Stream drop-down menu and select orderStream:1.0.0. In the As: text field, type orderStream and click Import.

6. Add the following queries in to the Query Expression field.

define table pizza_deliveries (deliveredTime long, order_id string);

from deliveryStream
select time, orderNo
insert into pizza_deliveries;

from orderStream#window.time(30 seconds)
insert into overdueDeliveries for expired-events;

from overdueDeliveries as overdueStream unidirectional join pizza_deliveries
on pizza_deliveries.order_id == overdueStream.orderNo
select count(overdueStream.orderNo) as sumOrderId, overdueStream.customerName
insert into deliveredOrders;

 You can try validating the query expression by clicking on 'Validate Query Expression' button.

6. Now export the deliveredOrders stream.

To do this, under Export Stream section,

i. Insert deliveredOrders into the Value of field.

ii. In the StreamId field, select 'Create Steam Definition'

iii. This will show the Define 'New Event Stream' window.

iv. Click 'Add Event Stream'

v. You will see the 'Stream Definition added successfully' message.

vi. Now you will see a prompt, asking “Defined event streams can publish out flow of events using event formatter. Do you want to create an event formatter now?” Close this pop up, since an event formatter will be created later.

vii. Then select the newly added Stream Definition, that is deliveredOrders from the StreamId field.

viii. Click 'Add' button, which is next to the StreamId field.

 7. Click 'Add Execution Plan'.

Step 6: Creating a datasource

In this example, we are inserting attributes in the exported stream into a mysql database. For this purpose, we need to create a reference to an already created database.

1. Navigate to Home > Configure > Data Sources
2. Click 'Add Data Sources'
3. This will show up the 'New Data Source' page.
4. Insert the following details:

Step 7: Creating an Output Event Adaptor

1. Navigate to Home > Configure > Event Processor Configs > Output Event Adaptors
2. Click 'Add Output Event Adaptor'

3. Insert the following details:

   Event Adaptor Name	MysqlOutputAdaptor
   Event Adaptor Type	mysql
   Data Source Name	TESTDB_MYSQL_DB

4. Test the connection. 'Connection is successful' message will be displayed upon successful creation of the connection.
5. Click 'Add Event Adaptor'

Step 8: Creating an Event Formatter

1. Navigate to Home > Manage > Event Processor > Event Streams
2. It will show up three available Event Streams.
3. Click on the 'Out-Flows' which belong to 'deliveredOrders:1.0.0' Event Stream. See the image below.
   
4. This will show up 'Event Out-Flows' page.
5. Click on 'Publish to External Event Stream(via Event Formatter)'
6. Insert the following details:

Click on Advanced and insert the following mapping:

7. Click 'Add Event Formatter'

8. A message will pop up saying 'Event formatter added successfully!!'

Step 9: Publishing data to CEP

1. Navigate to <CEP_HOME>/samples/producers/pizza-shop/ directory,  and execute the following command: ant pizzaPublisherClient

   As this publisher publishes data to the deliveryStream and orderStream streams, which were defined in Running the data publisher), the execution plan defined in 

   Adding an execution plan, will get executed. While the execution plan is running, the data created will get exported to deliveredOrders stream as specified in Adding an execution plan. When the deliveredOrders stream gets populated with data, the delivered_orders  MySQL table will also get populated, as a result of creating the PizzaDeliveryEventFormatter in Creating an Event Formatter.

Step 10: Creating the dashboard

After creating the table populated with useful information retrieved from complex event processing in Publishing data to CEP, follow the steps below to create a dashboard to display this data.

1. Navigate to Main > CEP Dashboard

2. This will prompt you to log in to the CEP Dashboard.

3. Insert 'admin' as username and 'admin' as password.

4. Now the CEP Dashboard will be loaded.

5. Click on 'Personalize'

6. Click on 'Create New Gadget'

7. 'Add Gadget' window will load.

8. In the 'Select Data Source' step ,select RDBMS, and click Next.

9.In the 'Configure Data Source' step, select 'TESTDB_MYSQL_DB ', and click Next.

10. Add 'select * from delivered_orders' in the SQL Statement field. Clicking 'Run' will show up the query results. Click Next.

11. In the 'Select a Gadget' step, select 'Bar Chart v1.0.0' and click 'Select Template'. Then click 'Next'.

12. In the last step: 'Preview', insert the following details:

Click on Preview. A preview should be displayed with the correct data.

13. Click 'Finish'.

14. The gadget is now inserted in to the CEP Dashboard.