TBD;
For basic operations look at basic sample For joins look at join sample
Look at QL sample.
Loot at FSM sample
Transforms aggregated data directly at Circe 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