Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink
Streaming machine learning using PyTorch, Flink, and ONNX
Flink Example
Use xgboost model to score data on Flink's datastream
hadoop study project
Jeenk: scalable genomics tools, powered by Apache Flink
Simple Flink job with MQTT sink function
Real-time Twitter analytic dashboards with Apache Flink, Elasticsearch and Kibana.
Pipeline components for real time data processing. Consists on a Flink module written on Scala.
A Flink demo project using Scala and SBT that analyzes HTTP log data from NASA.
This code helps making a real time alert platform for IoT etc.
This project provides Apache Spark SQL, Flink DataStream API examples in Scala language
Building the direct follower relation with Apache Flink streaming API
This is a basic example to show CEP in flink with kafka
Add a description, image, and links to the flink-stream-processing topic page so that developers can more easily learn about it.
To associate your repository with the flink-stream-processing topic, visit your repo's landing page and select "manage topics."