Skip to content

Commit

Permalink
Merge pull request #157 from jonatan5524/patch-1
Browse files Browse the repository at this point in the history
fix image ref typo
  • Loading branch information
kubeedge-bot authored Oct 30, 2024
2 parents bf492b0 + 9389358 commit e0ebb10
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 e0ebb10

Please sign in to comment.