This project provides Apache Spark SQL, Flink DataStream API examples in Scala language
-
Updated
Aug 18, 2023 - Scala
This project provides Apache Spark SQL, Flink DataStream API examples in Scala language
Flink connector for writing data into Amazon SageMaker Feature Store
CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
Rock The JVM - Apache Flink with Scala
Flink K8s Cluster Template
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Simple Flink example to use Flink DataStream and SQL APIs for solving the same and simple problem. Estimating the value Pi more and more precisely via Monte-Carlo trials.
A xml driven flinksql executor, for rapid development, testing, debuging, realtime compute platform, etc
Proxy to the internal Ververica Catalog via Ververica REST Api
A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.
Helps explain how Flink handles late arriving data and the effects on message order
Integrate monaco-languageclient with a Flink SQL LSP language server in Angular! Check out the Flink SQL web extension worker: https://www.npmjs.com/package/flink-sql-language-server
Add a description, image, and links to the flink-sql topic page so that developers can more easily learn about it.
To associate your repository with the flink-sql topic, visit your repo's landing page and select "manage topics."