-
Updated
Sep 5, 2018 - Java
flink-streaming
Here are 22 public repositories matching this topic...
This is an example application that streams real-time market data from Coinbase, and uses Apache Flink to process the stream
-
Updated
Feb 20, 2021 - Java
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
-
Updated
Feb 11, 2024 - Java
实时事件分析与决策引擎(Real-time event analysis and decision engine)
-
Updated
Oct 10, 2023 - Java
Starter templates for getting started with Apache Flink ( java-based stream processing library)
-
Updated
Aug 26, 2022 - Java
An approach to apply concept drifts and ADWIN on the streams event time to reason about the progress of watermarks
-
Updated
Nov 16, 2018 - Java
flink单词统计。包括table api和streaming使用,以及常见的数据源读写
-
Updated
Jan 27, 2021 - Java
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.
-
Updated
Dec 22, 2020 - Java
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
-
Updated
Jan 6, 2024 - Java
Information Systems, Analysis and Design Class Projects (2022-23, Fall Semester)
-
Updated
Mar 1, 2023 - Java
Adds ORC support to Flink Streaming File Sink
-
Updated
Oct 13, 2020 - Java
Demo Flink and Kafka project to show how to react on tracking events in real-time and trigger offer for customer engagement based on campaign configurations. The project also utilizes the Broadcast State Pattern in order to update the rules (campaigns) at runtime without restarting the project, using a dedicated, low-frequency, Kafka topic.
-
Updated
Feb 15, 2024 - Java
Keyed Watermarks in Apache Flink
-
Updated
Apr 21, 2024 - Java
第四代大数据计算引擎Flink - 从入门到实战
-
Updated
Aug 2, 2024 - Java
This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Grafana, everything deployed on Kubernetes (minikube).
-
Updated
Sep 5, 2023 - Java
Improve this page
Add a description, image, and links to the flink-streaming topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the flink-streaming topic, visit your repo's landing page and select "manage topics."