Apache Flink Training Excercises

A repository containing materials for Stateful Functions workshop

Jupyter Integration for Flink SQL via Ververica Platform

Demo code for implementing and showcasing a Fraud Detection Engine with Apache Flink.

Lab for testing different Flink job latency optimization techniques covered in a Flink Forward 2021 talk

This project contains a couple of tools to analyze data around the Apache Flink community.

Self-contained demo using Flink SQL and Debezium to build a CDC-based analytics pipeline. All you need is Docker! 🐳

Lab project to showcase Flink's performance differences between using a SQL query and implementing the same logic via the DataStream API

Self-contained demo using PyFlink with Gensim+spaCy to find topics in the Flink User Mailing List. All you need is Docker! 🐳

Flink visualization library for blogposts

The open-source skills library for Agentic Customer Success Operations. Hardened, multi-protocol playbooks designed for human CSMs and autonomous AI agents. Codifying technical API logic, expansion blueprints, and predictive churn-stop plays to close the Value Realization Gap. Licensed for internal business use. Please contribute & collaborate.

This lab demonstrates different ways to enrich data streams in Flink. This is part of the Deep Dive Masterclass of Flink Forward 2024.

Code examples for our blog post "Run PyFlink Jobs and UDFs in Ververica Platform"

Analyzing MUBI data with PyFlink (+ pandas) and interactive Zeppelin notebooks. 📈

This repo holds some examples of Flink jobs (custom resources of Ververica Platform) deployed using GitOps via a CI/CD tool.

Value in Motion™ is an autonomous AI agent — a Revenue Operating System for Customer Success.

HybridSource for files and Kafka source

Hop to it! Innovating Easter Egg Delivery with Ververica Cloud

Flink project example to rewrite savepoint with State Processor API