Skip to content
View abolfazlmadanii's full-sized avatar
🎯
Focusing
🎯
Focusing
3 followers · 4 following

Achievements

Achievement: YOLOAchievement: Pull Shark

Achievements

Achievement: YOLOAchievement: Pull Shark

Block or report abolfazlmadanii

Block user

Prevent this user from interacting with your repositories and sending you notifications. Learn more about blocking users.

You must be logged in to block users.

Content in all repositories owned by your account will be closed.
Maximum 250 characters. Please don’t include any personal information such as legal names or email addresses. This note will only be visible to you.
Report abuse

Contact GitHub support about this user’s behavior. Learn more about reporting abuse.

Report abuse
abolfazlmadanii/README.md

Hi, I'm Abolfazl Madani 👋

Data engineer working on streaming data modeling: how to model events, state, and time in Apache Flink and Kafka so results stay correct under late data, replays, and failures.

Now building

  • stream-patterns: a catalog of streaming data modeling patterns. Each pattern will ship with a reference model, a Flink SQL implementation, and tests. (in progress)
  • streamproof: a correctness test harness for Flink jobs, using seeded chaotic input, fault injection, and an oracle comparison. (in progress)
  • helion: streaming operators with proven error bounds (Count-Min, Space-Saving, pane windows) for Flink and Kafka Streams.

Upstream

  • Apache SeaTunnel: #11817, declarative option validation for the Email connector (merged).

Also

Stack: Apache Flink · Kafka · Iceberg · SQL · Python

📫 LinkedIn

Pinned Loading

  1. helion helion Public

    Streaming operators with proven error bounds (Count-Min, Space-Saving, pane windows) in Python, for PyFlink and quixstreams.

    Python

  2. metabase-jalali metabase-jalali Public

    Unofficial Jalali (Persian) calendar patch for Metabase OSS v0.63.14 — native Shamsi date picker and filters

    TypeScript

  3. Data-Engineering Data-Engineering Public

    Notes and examples across Apache Flink, Spark, Airflow, SQL, and Oracle.

    Java

  4. stream-patterns stream-patterns Public

    Catalog of streaming data modeling patterns (CDC, SCD2, late data, sessions, outbox) with runnable Python and PyFlink code. Early stage.

    Python

  5. streamproof streamproof Public

    Correctness test harness for streaming jobs: seeded inputs, fault injection, and an oracle to check results. Early stage.

  6. apache/seatunnel apache/seatunnel Public

    SeaTunnel is a multimodal, high-performance, distributed, massive data integration tool.

    Java 9.8k 2.5k