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

Last updated