Skip to content

Commit d0cde86

Browse files
Update readme.md
1 parent 34f54e5 commit d0cde86

File tree

3 files changed

+29
-2
lines changed

3 files changed

+29
-2
lines changed

README.md

+29-2
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
# DATA STREAM PROCESSING
1+
# DATA STREAM PROCESSING
22

33
## Overview
44

@@ -102,4 +102,31 @@ In the PostgreSQL connection, you should see the database `v9` and the table `pr
102102

103103
<p align = "center">
104104
<img src="assets/postgres.png" width = 80%>
105-
</p>
105+
</p>
106+
107+
- **Step 3. Start Streaming Data to MinIO**
108+
```bash
109+
python3 stream_processing/delta-to-minio.py
110+
```
111+
112+
After putting data to MinIO storage, you can go to the port http://localhost:9001 and see the result like this image
113+
114+
<p align = "center">
115+
<img src="assets/minio.png" width = 80%>
116+
</p>
117+
118+
## Read streaming data with Trino and Dbeaver
119+
120+
### Connect Trino in Dbeaver
121+
122+
<p align = "center">
123+
<img src="assets/trino_connect.png" width = 80%>
124+
</p>
125+
126+
### Query with Dbeaver
127+
128+
Create your Trino schema and table in Dbeaver
129+
130+
```sql
131+
132+
```

assets/minio.png

290 KB
Loading

assets/trino_connect.png

172 KB
Loading

0 commit comments

Comments
 (0)