Streaming IoT Analytics

Run Quarks on Edge devices like Raspeberry Pi and send back the relevant signals to MQTT platform


import java.util.concurrent.TimeUnit;

import org.apache.edgent.topology.TStream;
import org.apache.edgent.topology.Topology;

public class TempSensorApplication {
    public static void main(String[] args) throws Exception {
        TempSensor sensor = new TempSensor();
        DirectProvider dp = new DirectProvider();
        Topology topology = dp.newTopology();
        TStream<Double> tempReadings = topology.poll(sensor, 1, TimeUnit.MILLISECONDS);
        TStream<Double> filteredReadings = tempReadings.filter(reading -> reading < 50 || reading > 80);


Why Edge Analytics so crucial ?

Excepts from ~

— IoT sensor data monitoring and analysis
— Retail Customer behavior analysis
— Mobile data thinning
— Compliance analysis at financial branch locations
— Remote monitoring and analysis for oil and gas operations

more details: