twalthr / flink-api-examples
Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.
☆62Updated last year
Alternatives and similar repositories for flink-api-examples:
Users that are interested in flink-api-examples are comparing it to the libraries listed below
- ☆47Updated 6 months ago
- Code Samples for my Ververica Webinar "99 Ways to Enrich Streaming Data with Apache Flink"☆40Updated 3 years ago
- One bite-sized tip or trick for Apache Flink practitioners every day leading up to Christmas Eve 2024.☆24Updated 2 months ago
- ☆79Updated last year
- 📚 Tech blogs & talks by companies that run Apache Flink in production☆163Updated 3 weeks ago
- Multi-hop declarative data pipelines☆109Updated last week
- In-Memory Analytics for Kafka using DuckDB☆89Updated this week
- The Internals of Spark on Kubernetes☆70Updated 2 years ago
- ☆40Updated last year
- ☆25Updated 5 months ago
- Example of a tested Apache Flink application.☆42Updated 5 years ago
- Presto Trino with Apache Hive Postgres metastore☆40Updated 5 months ago
- Examples of Spark 3.0☆47Updated 4 years ago
- Sample processing code using Spark 2.1+ and Scala☆51Updated 4 years ago
- Low Cost, Simple and Scalable Way of Data Replication to Apache Iceberg/Cloud/Data Lake☆228Updated this week
- A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino☆19Updated 2 years ago
- A testing framework for Trino☆26Updated 3 months ago
- A Kafka Serde that reads and writes records from and to Blob storage (S3, Azure, Google) transparently.☆57Updated last week
- Apache Flink Guide☆54Updated 3 years ago
- Code snippets used in demos recorded for the blog.☆29Updated this week
- Apache Flink Stateful Functions Playground☆131Updated last year
- ☆53Updated this week
- The Workload Analyzer collects Presto® and Trino workload statistics, and analyzes them☆135Updated last year
- A temporary home for LinkedIn's changes to Apache Iceberg (incubating)☆62Updated 2 months ago
- BigQuery connector for Apache Flink☆29Updated this week
- CLI tool to bulk migrate the tables from one catalog another without a data copy☆75Updated this week
- Spark stream from kafka(json) to s3(parquet)☆15Updated 6 years ago
- a curated list of awesome lakehouse frameworks, applications, etc☆21Updated last month
- ☆17Updated 2 years ago
- Code for Apache Hudi, Apache Iceberg and Delta Lake analysis☆9Updated last year