A simple introduction to Apache/Flink CEP. Working with time window aggregation and simple match expression.

Twitter Flink Streaming data project

Learn how to build an end-to-end streaming architecture to ingest, analyze, and visualize streaming data in near real-time

Pet project to grow Apache Flink skills

Stream processing

learn flink with java

Developing a cost model and modifying the Apache Flink scheduler to efficiently offload tasks to edge systems, ultimately improving latency problems over the WAN.

A Makeshift data infrastructure setup for datafirstjobs.com.

This project provides Apache Spark SQL, Flink DataStream API examples in Scala language

Flink: KMeans Clustering Paralellism

This repository contains my coursework projects for the Big Data course in my Master's degree program.

Ecommerce Sales Analytics Data Generation, developed a detailed system architecture using Apache Flink, Kafka, Elasticsearch, and Docker. Implemented real-time data streaming, established a robust, scalable data pipeline. Flink was set up, transactions were aggregated in Postgres and Elasticsearch, concluding with a dynamic streaming dashboard.

Apache Flink job to correlate telecom signaling messages for KPI extracted from streaming solutions

This repository contains my coursework projects for the Big Data course in my Master's degree program.

we are thrilled to announce our new PoC project aimed at providing a complete real-time extraction, transformation, and exposure architecture for the new provincial transportation systems.

Building the direct follower relation with Apache Flink streaming API

Includes examples for Apache Flink

Pipeline components for real time data processing. Consists on a Flink module written on Scala.

Arquitectura pipeline para streaming de tiempo real