Here are 57 public repositories matching this topic...

MoriatyBug / flink-commodity-recommendation-system

Star 112

🐳基于 Flink 的商品实时推荐系统。当用户产生评分行为时，数据由 kafka 发送到 flink，根据用户历史评分行为进行实时和离线推荐。实时推荐包括：基于行为和实时热门，离线推荐包括：历史热门、历史优质商品和 itemcf 。

recommendation-system flink flink-stream-processing streamprocessing flink-kafka flink-recommend

• Updated Sep 16, 2020
• Java

streamnative / pulsar-flink

Star 91

Elastic data processing with Apache Pulsar and Apache Flink

schema sql catalog schema-registry stream-processing apache-flink flink data-processing batch-processing flink-stream-processing apache-pulsar flink-connector

• Updated Dec 12, 2020
• Java

mickey0524 / flink-streaming-source-analysis

Star 31

flink 流处理源码分析

flink flink-stream-processing source-analysis

• Updated Sep 8, 2019
• Java

TU-Berlin-DIMA / scotty-window-processor

Star 28

Open

Create seperate Demo folder

PhilippGrulich commented Sep 13, 2019

We should create a separate demo folder, which contains all demos and examples currently contained in the connectors.

Read more

good first issue

Open

Add Apache license to all files

Open

Add log4j for log output

hey-johnnypark / apache-flink-jdbc-streaming

Star 19

Sample project for Apache Flink with Streaming Engine and JDBC Sink

mysql protobuf jdbc apache apache-flink flink flink-stream-processing

• Updated Apr 1, 2017
• Java

Anant / cassandra.realtime

Star 17

Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink

kafka akka spark cassandra spark-streaming kafka-connect flink flink-stream-processing flink-streaming

• Updated Dec 7, 2020
• Scala

BrooksIan / Flink2Kafka

Star 10

A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink

intellij-idea flink-examples flink-stream-processing flink-kafka

• Updated Jun 18, 2020
• Java

aws-samples / amazon-kinesis-data-analytics-flink-benchmarking-utility

Star 7

Amazon Kinesis Data Analytics Flink Benchmarking Utility helps with capacity planning, integration testing, and benchmarking of Kinesis Data Analytics for Apache Flink applications.

flink-stream-processing kinesis-data-analytics kinesis-streams

• Updated Oct 2, 2020
• Java

zlzhang0122 / flink-in-action

Star 7

基于Flink的批流处理实战案例

java flink flink-stream-processing

• Updated Oct 13, 2020
• Java

Adsizzlerlabs / mangolaa-streams-processing-flink

Star 6

Stream processing for the Mangolaa platform using Apache Kafka, Apache Flink, Java 8 and Lombok

lombok stream-processing java-8 apache-flink flink-stream-processing

• Updated Apr 5, 2018
• Java

galgus / flink-connector-http

Star 5

Flink HTTP Sink Connector

https apache flink sink-connector flink-stream-processing

• Updated Oct 2, 2019
• Java

AndyXGWang / B2C-User-Profile-Project

Star 4

基于Flink流处理的动态实时亿级电商全端用户画像系统

nodejs java profile elasticsearch vuejs spark flink flink-stream-processing flink-kafka hadood

• Updated Apr 11, 2019

ehabqadah / Spark_Streaming_vs_Flink

Star 3

A Comparative Evaluation of Spark and Flink Stream Processing.

java benchmarking kafka spark latency bigdata spark-streaming throughput flink flink-stream-processing

• Updated Nov 22, 2017
• Java

fediazgon / flink-vehicle-telematics

Star 3

Stream processing of simulated on-vehicle sensors data

stream-processing flink sensor-data flink-stream-processing

• Updated Jul 28, 2019
• Java

ankushs92 / apache-flink-aggregations-clickstreams

Star 3

Count clicks in an unbounded clickstream over a Time window using Apache Flink's DataStream API

stream-processing apache-flink clickstream flink-stream-processing

• Updated Mar 22, 2018
• Java

thomas-chauvet / predict-xgboost-flink

Star 3

Use xgboost model to score data on Flink's datastream

docker machine-learning docker-compose stream-processing xgboost flink interpretability flink-examples flink-stream-processing

• Updated Mar 28, 2019
• Scala

crs4 / Jeenk

Star 2

Jeenk: scalable genomics tools, powered by Apache Flink

kafka genomics flink-stream-processing

• Updated Apr 30, 2018
• Scala

marlesson / simple_weblog_analysis_flink

Star 2

Simple example for access count in Apache logs using Apache Flink

log flink flink-stream-processing access-count

• Updated Sep 29, 2017
• Python

raymondtay / tube

Star 2

The pipeline for Slack

cats scala akka akka-http http4s circe eff flink-stream-processing

• Updated Feb 13, 2020
• Scala

nwrs / tempest-streamer

Star 2

Real-time Twitter analytic dashboards with Apache Flink, Elasticsearch and Kibana.

elasticsearch kibana twitter twitter-streaming-api flink flink-stream-processing

• Updated Oct 7, 2018
• Scala

iNaDeX / KafkaConsumer

Star 2

Process streaming data from Kafka with Flink and store it in ElasticSearch

elasticsearch twitter kafka sentiment-analysis kafka-consumer flink flink-stream-processing flink-kafka

• Updated Mar 18, 2018
• Java

mgoblin / streaming_examples

Star 1

stream-processing flink flink-stream-processing

• Updated Feb 19, 2018
• Scala

e3oroush / flink-tutorial

Star 1

A simple introduction to Apache/Flink CEP. Working with time window aggregation and simple match expression.

java cep flink flink-examples flink-stream-processing complex-event-

• Updated Jul 13, 2019
• Java

mgoblin / streams

Star 1

Pet project to grow Apache Flink skills

flink flink-stream-processing

• Updated Mar 25, 2018
• Scala

triviadata / streaming-playground

Star 1

kafka akka spark-streaming kafka-streams streaming-data flink-stream-processing

• Updated May 24, 2018
• Java

froblesmartin / BachFinalProject

Star 1

Test codes for Spark Streaming and Flink in my bachelor's final project

benchmarking benchmark streaming kafka big-data spark apache spark-streaming flink flink-stream-processing spark-streaming-kafka flink-kafka

• Updated Jun 25, 2017
• Java

sparsecode / Streamy

Star 1

streaming real-time stream-processing event-driven flink-stream-processing flink-streaming

• Updated Jul 8, 2019
• Scala

ASKRAJPUT5 / flink-Table

Star 0

This code helps making a real time alert platform for IoT etc.

scala kafka sbt apache-flink kafka-streams flink-stream-processing flink-kafka flink-cep flink-kafka-consumer flink-table

• Updated Oct 14, 2019
• Scala

tonvanbart / flink-mqtt

Star 0

Simple Flink job with MQTT sink function

scala flink-stream-processing mqtt-connector

• Updated Jul 7, 2020
• Scala

ma-silva / direct-follower-relation-flink

Star 0

Building the direct follower relation with Apache Flink streaming API

scala flink flink-stream-processing

• Updated Apr 21, 2018
• Scala

Load more…