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
Proxy to the internal Ververica Catalog via Ververica REST Api
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 SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
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.
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
Flink K8s Cluster Template
Helps explain how Flink handles late arriving data and the effects on message order
A xml driven flinksql executor, for rapid development, testing, debuging, realtime compute platform, etc
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.
Flink Example
Flink SQL extension for Visual Studio Code
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."