Trembita kernel

TBD;

Basic

For basic operations look at basic sample For joins look at join sample

QL

Look at QL sample.

FSM

Loot at FSM sample

Serialization

Transforms aggregated data directly at Circe sample

Complex sample

Trips contains a real-life example of processing real-time vehicle data.

Having a message with different metrics using FSM you are allowed to define generic transformation from single message into DrivingActivity (trip either idle). Based on those activities you are allowed to aggregate your data using QL into some kind of report.

Data is fetched from Cassandra using phantom connector (tables are defined in UnitMessagesRepository)

P.S. This saved a lot of time when developing over 30 kind of reports