Complex Event Processing(CEP)

• CEP Introduction
  • Purpose of the Document
  • Reference Document
• Create Rule
  • MultipleStreamJoining/filtering/SQL on streaming data
    • Joining two streams based on common feature of interest and window of 1 minute
    • Sample rule with standard sql functions(difference between the temp values in a room and the maximum value of temp in the same room)
    • Sample rule with standard sql functions(calculating count of a field)
    • Filtering rule with current and previous values of a field
    • Filtering rule with current and next values of a field
    • Filtering rule with rank of a field based on order by value descending of that field
    • Joining more than two Streams within window with multiple join conditions
    • Joining streaming data with static tables
    • Executing user defined functions(udf) with streaming data
    • Posting output streaming data to Delta Lake
    • rule with maxLateArrivalDelay
  • PureAggregation with Filtering
    • Aggregation of Multiple Streams within window and filtering
    • Calculate Moving average of a field
    • Filtering on Running count of a field
    • Calculate sum of a field over the window of 60 seconds with 30 seconds overlapping window
    • Posting output streaming data to delta lake
    • rule with maxLateArrivalDelay
• Describe Rule
  • Get All Rules
  • Get Rule by ID
• Operation on Rule
  • Start the rule
  • Stop the rule
  • Update the rule
  • Delete a rule
• Execute and View Result
  • Event Selections
    • Publish Observation Data
  • Operations on Events
  • Actions
• Appendix
  • Use Case 1
    • Operation Sequences
    • Rule Statement
    • Sensors Used
    • CEP Rule Used
  • Use Case 2
    • Operation Sequences
    • Rule Statement
    • Sensors Used
    • CEP Rule Used