Streaming Analytics
Continuous analytic processing over streaming events
Joule offers a user-friendly streaming analytics capability tailored to deliver real-time insights efficiently. It enables users to harness existing analytical resources, define expressions, integrate reference data, and develop custom analytic plugins for complex calculations.
Key features
Expression evaluation and execution
Scripting and function execution
Stateful calculations
Calculation seeding with start values
Constants and reference data
Analytic result memory
Additionally developers can extend the analytical capabilities by implementing various analytics APIs. drive business the ability to execute imperative expressions, functions and scripts. Platform users can deploy custom stateful and stateless analytics using the Joule DSL using analytics processors.
Analytic Processor Overview
Available features
Javascript and Python are supported using the Graalvm runtime compilation engine
Worked example
This example demonstrates how two independent computed analytic pipeline results can be combined to generate an alerting signal.
Stage 1 - Pre-processing
Enrich event with signal thresholds using the internal in-memory database.
Stage 2 - Event window analytics
Perform complex analytics using event based sliding windows and a stateful analytic function (exponential mean average).
Stage 3 - Analytics
Combine the results of the stateful analytics in to two basic difference calculations using Javascript notation/
Stage 4 - Alerting Rules
Finally once the calculations have been completed perform the final predicate using the having
expression to send an alerting event to a downstream system
Last updated