Core concepts
Joule enables you to build stream processing pipelines that subscribes to source data and publish processed events to destination sinks
Concepts
The following sections describes the concepts you need to know to use Joule.
Event Sources
Data sources provide Joule with the required data to execute use cases. Fractalworks has provided a number of ready to use implementations to enable you to start building use cases.
Implementations include
Kafka
RabbitMQ
File Watcher
Minio S3
Rest
MQTT
See sources documentation for further details
Stream Processors
Processors form the core of the Joule platform. A processor performs a distinct unique function when chained with others form a business use case
Implementations include
Enricher
Transformations
Online prediction
Event window analytics
And much more
See processors documentation for further details
Data Sinks
Data sinks enable Joule to integrate to downstream systems which provide further value to additional business cases
Implementations include
Kafka
Websocket
SQL Databases
InfluxDB
Apache Geode
And much more
See sinks documentation for further details
Joule Domain Specific Language
The Joule platform provides a Domain Specific Language (DSL) to define use cases using human-readable yaml syntax.
See Joule DSL documentation for further details
Last updated
