v1.2.0 Join Streams with stateful analytics

Join real-time stream events for advance state based analytics and customer centric insights

Version 1.2.0

Download Banking example project

Download Joule Platform

Docker Image

Overview

Joule’s latest release offers businesses a comprehensive solution to accelerate use case development to generate value while minimising risk. The platform leverages dynamic ML models, metrics, reference data, and observability to provide real-time actions and insights.

With Joule, businesses can streamline their development efforts and make informed decisions based on data-driven insights. Joule’s intuitive development platform and user-focused design make it easy for businesses to leverage the power of data and maximise their potential.

Features

• Real-time Dual Stream Joins

• Normalisation, scaling and statistic ML functions

• Stateful analytics

• Advanced Javascript support

• Support for Kafka partitioning strategies

• Extended enrichment capabilities for metrics etc

• Metrics engine priming with seed values

• Documentation improvements

---

Stream Join

Join independent stream events to trigger advance analytical insights and dynamic business rules

• Ability to join two streams using a simple join expression

• Inner and outer joins support

• State managed either through an time to live function or simply delete on join

Analytics

• New normalisation, scaling, and statistics functions for ML support
• Stateful computation support

• Simplified DSL to enable correct processor to be used

Enrichment Processor

• Computed metrics can be added to events using a lookup key

• Internal in-memory database can be queried for event enrichment

Metrics

• Import pre-computed metrics on process startup

• User defined metrics compaction query

---

Enhancements

Analytics

• Improvements and bug fixes to address execution of expressions and scripts

Geospatial Processors

Geospatial processor DSL improvements, hardening and finally documentation

• Entity geo tracker

• Geo search

• IP location resolver

• Geo reverse lookup

• Spatial Index

Scripting

• Javascript module mjs support

Kafka

• Validated consumer message partition strategies for multi Joule processing use cases

General

• groupby definition support across all processors

Documentation

Improvements to following areas:

• Getting started with Joule

• Monitoring

• Geospatial

• Analytics

Upgrades

• DuckDB 1.0.0

Bug Fixes

Fixed scripting processor bug whereby script functions could not be executed