Proton101

Introduction

Proton is a streaming SQL processor developed by the ClickHouse team and written in C++. It is designed to be easier and faster than Apache Flink. I plan to test it out here, initially using its client, and later by writing some code.

Using Proton Client

First, run the docker compose:

docker compose up

Then, attach into it:

docker exec -ti proton101-proton-1 bash

proton-client

and create a random stream using its client:

CREATE RANDOM STREAM devices(
                  device string default 'device'||to_string(rand()%4),
                  temperature float default rand()%1000/10)

you can query the real-time data as follows:

SELECT device, count(*), min(temperature), max(temperature)
FROM devices GROUP BY device