4 Streaming complex event processing

In this chapter you’ll be working with streaming events, which is data that is observed intermittently and without access to complete data.  If you’ve ever watched the old I Love Lucy – The Chocolate Factory episode, you already have a mental picture of what streaming events are all about. In the main scene, Lucy and Ethel are instructed to wrap pieces of candy as they roll down a conveyer belt in single row. Lucy and her friend are sternly warned to not let a single piece of candy make its way past them to the packing room without being wrapped.   The stream, in this case a conveyer belt, continuously rolls out new events (chocolates). While the event stream (conveyer belt) appears to be moving at a manageable pace Lucy and Ethel very soon find themselves stuffing candy events in their mouths and down their shirts to avoid downstream (the boss) alerts detection. When it is apparent to Lucy that their event- processing technique is not effective in dealing with the onslaught of candies she yells to Ethel, “I think we are fighting a losing game.”

4.1       What is streaming data

4.1.1   Data in transit versus data at rest

4.1.2   Where are data streams typically found

4.2       What is complex event processing

4.2.1   What is event processing

4.2.2   Event processing involving time

4.2.3   When might you want to enrich a data stream?

4.2.4   When might you want to relate two events?

4.3       Complex event processing in edge computing

4.3.1   Downloading the CEP plugin

4.3.2   Launching your agent and dashboard

4.3.3   Building your CEP

4.3.4   Uploading the CEP plugin to the agent registry

4.3.5   Adding and configuring plugins in the application builder

4.3.6   Submitting your edge application

4.4       Summary