Page Comparison

Anchor

step 4

step 4

Step 4: Running the data publisher

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

ant pizzaPublisherClient

Anchor

step 5

step 5

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 orderStreamand 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'

Anchor