Skip to content
View rfim's full-sized avatar
💭
Working from Home
💭
Working from Home

Organizations

@klinik-jalanan

Block or report rfim

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. Markdown is supported. 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
rfim/README.md

hi, i'm vim 👋

Animated NEXUS architecture: two valid records continue to delivery while one invalid record branches into quarantine, is corrected, and replays

I build data platforms that keep moving when real data gets messy. I'm a Senior Data Engineer in London, with 10+ years across insurance, fintech and enterprise, from Deloitte consulting to insurtech scale-ups.

Real data rarely follows the diagram: rows fail, updates repeat, and schemas drift. NEXUS follows that journey from messy events to trusted business answers. The examples are synthetic; the engineering choices reflect my work. Making an answer survive a Tuesday is the interesting part.

NEXUS — one bad row, no blocked batch

Three records arrive: two pass, one fails. The good rows move on; the exception keeps its reason until correction and replay. No batch-wide pause for one indecisive row. Explore the architecture and working code.

One YAML — many ingestion routes

Animated multi-tenant ingestion design: one YAML file expands into three independently checkpointed tenant routes, each landing in Delta Bronze

One YAML declares each tenant's source, contract, checkpoint, Bronze destination and quarantine path. Aurora can pause and replay while Beacon and Cedar continue. Inspect the example YAML.

CDC — when the source changes

Animated CDC design: one event is applied, a replay becomes a no-op, and a new personal field is held while AI drafts a metadata-only suggestion for human review

Aurora's first update applies; its replay is a no-op, and older state cannot win. A new customer_phone field holds Aurora at the contract gate while other tenants continue. A mock AI hook suggests a classification from schema metadata; a reviewer decides whether to change the contract and replay. Inspect the CDC design and runnable reference.

Non-CDC — safe self-healing

Animated file ingestion design: an approved decimal cast repairs one row, an invalid value is quarantined, a repeat file is a no-op, and a new field is held for review

Beacon's file gets one approved decimal cast, one row quarantined, and two rows into Bronze. A retry is a no-op; a new field waits for review. The AI hook can suggest, not approve. Boring rules are welcome when money is involved. Inspect the design and runnable reference.

NEXUS Cortex — from trusted rows to trusted answers

Synthetic NEXUS Cortex concept animation: a yellow Agumon answers a paid-orders question by resolving an approved metric, applying tenant scope, querying Gold, and showing evidence

Clean rows still need shared meaning. In this design concept, Agumon answers a synthetic paid-orders question using an approved metric, tenant policy and Gold data, with definition, freshness and lineage attached. The chatbot is illustrative, not deployed. See the semantic-layer blueprint.


Your turn — Pipeline Rush

Animated Pipeline Rush preview: clean records reach Gold, a duplicate is fixed at the Silver gate, and a corrupt row is quarantined

60 seconds. Keep Gold clean. Catch the duplicate, quarantine the corrupt row, and move the good data through before the SLA clock hits zero.

Start Pipeline Rush


🧰 Toolkit

Platforms
Databricks Snowflake BigQuery Redshift PostgreSQL

Processing
Apache Spark dbt SQL Python

Streaming & CDC
Kafka Pulsar Debezium

Orchestration & ops
Airflow Dagster GitHub Actions Terraform Docker

Quality & governance
data contracts: enforced ✓ Great Expectations: all passing Unity Catalog: governed lineage: source → dashboard

Modelling
Kimball: ⭐ star schema Data Vault: hubs · links · sats medallion: 🥉 → 🥈 → 🥇


🎓 Teaching

  • Kelas Semanggi: open source data engineering curriculum I maintain
  • HACKTIV8: teaching Databricks, Spark, dbt and dimensional modelling to career switchers since 2019

✍️ Writing

Notes on data platforms and engineering on Medium.


📫 Get in touch

LinkedIn · Medium

Open to senior and lead data engineering roles in London and remote UK.

Popular repositories Loading

  1. DEAP-SimpleExample-Notebook DEAP-SimpleExample-Notebook Public

    ( 🦉 ) This code lab intended to introduce new Machine Learning Algorithm // DEAP : Distributed Evolutionary Algorithm Framework.

    Jupyter Notebook 3 5

  2. ProcessMining-105 ProcessMining-105 Public

    (🔬) This code lab can connect with various databases and load multidimensional event logs in which the characteristics of the process-instance are modeled as dimensions in a data warehouse-like sc…

    C# 1

  3. Microstrategy Microstrategy Public

    ( 📈 ) Code lab for sharing SDK of Microstrategy front end using IOS mobile as business intelligence presentation layer.

    C++ 1

  4. SemanticMobileSyncrhonization SemanticMobileSyncrhonization Public archive

    This code lab is based on semantic apps using Apache Jena framework 🕸 .

    Java

  5. awesome-ruby awesome-ruby Public archive

    Forked from markets/awesome-ruby

    💎 A collection of awesome Ruby libraries, tools, frameworks and software

  6. sparklyr sparklyr Public

    Forked from sparklyr/sparklyr

    Code lab for R interface custom modification for Apache Spark. [⚙️]

    R