Stream processing
-
Updated
Sep 16, 2019
Stream processing
This is an example application that streams real-time market data from Coinbase, and uses Apache Flink to process the stream
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.
norns-job 快速开发spark/flink任务
flink单词统计。包括table api和streaming使用,以及常见的数据源读写
Flink K8s Cluster Template
TweetPipe Apache Flink AWS Kinesis Consumer. A Flink-based consumer that reads from an AWS Kinesis source and maps the input stream elements to a domain model. Future iterations will output the transformed data to a sink.
This repository contains an Apache Flink application for real-time sales analytics built using Docker Compose to orchestrate the necessary infrastructure components, including Apache Flink, Elasticsearch, MySQL, and Postgres
Keyed Watermarks in Apache Flink
Add a description, image, and links to the flink-streaming topic page so that developers can more easily learn about it.
To associate your repository with the flink-streaming topic, visit your repo's landing page and select "manage topics."