Skip to content

Commit

Permalink
doc: fix broken link to images
Browse files Browse the repository at this point in the history
  • Loading branch information
feber authored Nov 26, 2021
1 parent 9ce0a1c commit c4a4c35
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions apache-beam-analysis/README.md
Original file line number Diff line number Diff line change
Expand Up @@ -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.

Expand All @@ -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+)
Expand Down

0 comments on commit c4a4c35

Please sign in to comment.