Ingest, Enrich, Sessionize, aggregate, and store clickstream Data in real time
-
Updated
Dec 17, 2024 - Scala
Ingest, Enrich, Sessionize, aggregate, and store clickstream Data in real time
Row pattern matching in DuckDB with SQL — SQL:2016 MATCH_RECOGNIZE (PARTITION/ORDER/PATTERN/DEFINE/MEASURES) for sequences: V-shapes, funnels, sessionization, event patterns. A VGI worker.
Python challenge: merge user events into sessions with deep meta merge, ordered type counts, and Dockerized tests.
Real-time Kafka clickstream pipeline with sessionization, consumer groups, PostgreSQL, and Docker.
Apache Beam pipeline demonstrating a two-tiered state architecture for high-performance entity building and session reconstruction from out-of-order streaming events. Official demo for Beam College 2026 talk.
Product analysis of 2.76M real e-commerce events: session funnel, cohort retention, behavioral segments, and cart-recovery A/B test design.
An emotionally intelligent analytics platform built from Spotify Extended Streaming History JSON exports (2021–2026). Dark, cinematic UI with probabilistic behavioral narratives, not pseudoscience.
SQL-first (DuckDB) analysis of Spotify listening behavior: sessionization, cohort retention, taste concentration, and a hypothesis test.
Sessionization pipeline for SEC EDGAR access logs
Looker Block for Sessionization of the track-type events in the RudderStack platform.
Behavior-based web scraping & abuse detection pipeline using sessionization and explainable rules.
Using DBT for Creating Session Abstractions on RudderStack - an open-source, warehouse-first customer data pipeline and Segment alternative.
To associate your repository with the sessionization topic, visit your repo's landing page and select "manage topics."