flink-stream-processing

Here are 69 public repositories matching this topic...

MoriatyBug / flink-commodity-recommendation-system

Star 231

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

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

• Updated Sep 16, 2020
• Java

streamnative / pulsar-flink

Star 204

Elastic data processing with Apache Pulsar and Apache Flink

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

• Updated Aug 12, 2021
• Java

TU-Berlin-DIMA / scotty-window-processor

Star 37

Open

Add Apache license to all files

PhilippGrulich commented Sep 13, 2019

We have to add the Apache License to all files

Read more

good first issue

Open

Add log4j for log output

mickey0524 / flink-streaming-source-analysis

Star 36

flink 流处理源码分析

flink flink-stream-processing source-analysis

• Updated Sep 8, 2019
• Java

hey-johnnypark / apache-flink-jdbc-streaming

Star 22

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

zlzhang0122 / flink-in-action

Star 20

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

java flink flink-stream-processing

• Updated Aug 8, 2021
• Java

Anant / cassandra.realtime

Star 20

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 May 21, 2021
• Scala

BrooksIan / Flink2Kafka

Star 13

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

cjermain / flink-onnx-pytorch

Star 8

Streaming machine learning using PyTorch, Flink, and ONNX

machine-learning streaming pytorch flink flink-stream-processing onnx flink-streaming onnxruntime

• Updated May 20, 2021
• Scala

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

Star 8

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 Jun 10, 2021
• Java

Adsizzlerlabs / mangolaa-streams-processing-flink

Star 7

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 7

Flink HTTP Sink Connector

https apache flink sink-connector flink-stream-processing

• Updated Apr 19, 2021
• Java

ehabqadah / Spark_Streaming_vs_Flink

Star 4

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

ankushs92 / apache-flink-aggregations-clickstreams

Star 4

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

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

thomas-chauvet / predict-xgboost-flink

Star 4

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

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

arkady-emelyanov / toy-data-platform

Star 3

Toy data platform for a company that provides web analytics

golang terraform helm web-analytics message-bus apache-beam redash apache-kafka fasthttp flink-stream-processing apache-druid spark-stream-kafka

• Updated Mar 31, 2021
• HCL

marlesson / simple_weblog_analysis_flink

Star 3

Simple example for access count in Apache logs using Apache Flink

log flink flink-stream-processing access-count

• Updated Sep 29, 2017
• Python

e3oroush / flink-tutorial

Star 2

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

crs4 / Jeenk

Star 2

Jeenk: scalable genomics tools, powered by Apache Flink

kafka genomics flink-stream-processing

• Updated Apr 30, 2018
• Scala

EJASKHAN / flink-consume-produce-ek

Star 2

This FLINK project will consume streams from an azure event-hub and produce to a different event-hub ,and the config files for deploying the same in kubernetes

java docker kubernetes azure k8s flink k8s-cluster kubernetes-deployment flink-examples flink-stream-processing savepoint eventhub k8s-deployment checkpointing ejaskhan

• Updated Feb 2, 2021
• Java

raymondtay / tube

Star 2

Apache Flink Data Pipelines for processing Slack data

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

• Updated Mar 7, 2021
• 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

tonvanbart / flink-mqtt

Star 1

Simple Flink job with MQTT sink function

scala flink-stream-processing mqtt-connector

• Updated Feb 2, 2021
• Scala

mgoblin / streams

Star 1

Pet project to grow Apache Flink skills

flink flink-stream-processing

• Updated Mar 25, 2018
• Scala

yahah100 / flink_streaming_twitter

Star 1

Twitter Flink Streaming data project

elasticsearch kibana big-data flink flink-stream-processing

• Updated Apr 2, 2020
• Java

sparsecode / Streamy

Star 1

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

• Updated Jul 8, 2019
• Scala