From 9389358d02cf1fd00f8930f4a787a3d1081b1941 Mon Sep 17 00:00:00 2001 From: Yehonatan Ezron <37303618+jonatan5524@users.noreply.github.com> Date: Thu, 5 Sep 2024 16:52:35 +0300 Subject: [PATCH] fix image ref typo change image reference from images to Image like the folder Signed-off-by: jonatan --- apache-beam-analysis/README.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/apache-beam-analysis/README.md b/apache-beam-analysis/README.md index 78c9ae7bc..6bd0686a8 100644 --- a/apache-beam-analysis/README.md +++ b/apache-beam-analysis/README.md @@ -2,7 +2,7 @@ ## Description -![High level architecture](images/High_level_Arch.png "High Level Architecture") +![High level architecture](Images/High_level_Arch.png "High Level Architecture") The main aim of analytics engine is to get data from mqtt broker in stream format and apply rules on incoming data in real time and produce alert/action on mqtt broker. Getting data through pipeline and applying analysis function is done by using Apache Beam. @@ -25,12 +25,12 @@ There are many frameworks like Hadoop, Spark, Flink, Google Cloud Dataflow etc f - Create PCollection of read data and use it as the initial data for pipeline - Do a filtering over the data - Publish an alert on a topic if reading exceeds the value -![Demo1.1](images/Demo1.1.png "Demo1.1:Read batch data from MQTT,filter and generate alerts") +![Demo1.1](Images/Demo1.1.png "Demo1.1:Read batch data from MQTT,filter and generate alerts") #### Demo 1.2 [Filter Streaming Data]: Reads streaming data from MQTT, filter at regular intervals - Read streaming data using MQTT - Do a filtering over the data at fixed time intervals -![demo1.2](images/Demo1.2.png "Demo1.2:Reads streaming data from MQTT, filter at regular intervals") +![demo1.2](Images/Demo1.2.png "Demo1.2:Reads streaming data from MQTT, filter at regular intervals") ### Prerequisites - Golang(version: 1.14+)