datavane/tis

Support agile DataOps Based on Flink, DataX and Flink-CDC, Chunjun with Web-UI

Language: Java - Size: 29 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 1,138 - Forks: 241

mikeroyal/Apache-Flink-Guide

Apache Flink Guide

Size: 171 KB - Last synced at: 24 days ago - Pushed at: over 3 years ago - Stars: 57 - Forks: 8

Anant/Cassandra.Realtime

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

Language: Scala - Size: 575 MB - Last synced at: 4 days ago - Pushed at: almost 3 years ago - Stars: 31 - Forks: 24

AhmetFurkanDEMIR/Flink-Example

Flink Example

Language: Scala - Size: 5.6 MB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 15 - Forks: 0

TawfikYasser/Keyed-Watermarks-in-Apache-Flink

Keyed Watermarks in Apache Flink

Language: Java - Size: 509 KB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 3 - Forks: 1

zsolt-donca/flink-alt

An alternative minimalistic API for Flink based on cats typeclasses, with a reference in-memory implementation.

Language: Scala - Size: 164 KB - Last synced at: 4 days ago - Pushed at: 2 months ago - Stars: 7 - Forks: 2

tashi-2004/Apache-Flink-Spark-Data-Streaming

This project showcases a real-time data streaming pipeline using Apache Flink, Apache Spark, and Grafana. It streams data, stores it in Parquet format, and performs aggregations for insights, with seamless visualization via Grafana dashboards.

Language: Python - Size: 62.6 MB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0

cjermain/flink-onnx-pytorch

Streaming machine learning using PyTorch, Flink, and ONNX

Language: Scala - Size: 33.2 KB - Last synced at: 12 days ago - Pushed at: almost 4 years ago - Stars: 25 - Forks: 10

innogames/flink-real-time-crm

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.

Language: Java - Size: 1.22 MB - Last synced at: 8 days ago - Pushed at: 6 months ago - Stars: 14 - Forks: 2

Java-Edge/Flink-Tutorial

第四代大数据计算引擎Flink - 从入门到实战

Language: Java - Size: 44.9 KB - Last synced at: about 1 month ago - Pushed at: 10 months ago - Stars: 7 - Forks: 3

threeknowbigdata/flink_second_understand

该仓库专注于让读者秒懂Flink组件，包含Flink实战代码和文档、200个Flink教程知识点，Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看：https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=getalbum&album_id=2038088622687469575#wechat_redirect

Language: Java - Size: 58.7 MB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 646 - Forks: 174

nkonev/flink-pipe

A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.

Language: Kotlin - Size: 78.1 KB - Last synced at: about 2 months ago - Pushed at: 12 months ago - Stars: 2 - Forks: 0

sparsecode/Streamy

Language: Scala - Size: 72.3 KB - Last synced at: about 1 year ago - Pushed at: almost 6 years ago - Stars: 1 - Forks: 0

Quocc1/Stream_Processing

This project aimed at providing real-time click attribution and dynamic e-commerce insights.

Language: Python - Size: 24.5 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

flink-extended/clink

Clink is a library that provides APIs and infrastructure to facilitate the development of parallelizable feature engineering operators that can be used in both C++ and Java runtime.

Language: C++ - Size: 3.18 MB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 27 - Forks: 12

ev2900/Flink_Kinesis_Data_Analytics

Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).

Language: Python - Size: 17.3 MB - Last synced at: about 1 month ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 11

nkonev/flink-connector-clickhouse Fork of itinycheng/flink-connector-clickhouse

Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.

Language: Java - Size: 273 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

hung2xt/streaming-with-apache-flink Fork of airscholar/FlinkCommerce

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

Language: Java - Size: 321 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

NornsLab/norns-job

norns-job 快速开发spark/flink任务

Language: Scala - Size: 841 KB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 3

john-papani/IoT-Live-streaming

Information Systems, Analysis and Design Class Projects (2022-23, Fall Semester)

Language: Java - Size: 7.22 MB - Last synced at: over 1 year ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 1

eoctet/event-senses-bot

实时事件分析与决策引擎（Real-time event analysis and decision engine）

Language: Java - Size: 80.1 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

mainakchhari/apache-flink-quickstart

Starter templates for getting started with Apache Flink ( java-based stream processing library)

Language: Java - Size: 1.95 KB - Last synced at: 7 months ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0

felipegutierrez/explore-flink

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).

Language: Java - Size: 28.5 MB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 39 - Forks: 21

sonhmai/flink-dynamodb-connector

Apache Flink DynamoDB connector

Language: Java - Size: 37.1 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0

chethanuk/flink-cluster-template

Flink K8s Cluster Template

Language: Python - Size: 105 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

DataSystemsGroupUT/Adaptive-Watermarks

An approach to apply concept drifts and ADWIN on the streams event time to reason about the progress of watermarks

Language: Java - Size: 527 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 9 - Forks: 0

Xikl/flink-in-action

Flink的学习

Size: 115 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 2

hbk671104/flink-cdc-demo

Language: Java - Size: 12.7 KB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 1

wuzguo/hadoop-study

hadoop study project

Language: Scala - Size: 28.4 MB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 3 - Forks: 0

mattczyz/flink-orc

Adds ORC support to Flink Streaming File Sink

Language: Java - Size: 57.6 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 9 - Forks: 1

handsomestWei/flink-word-count

flink单词统计。包括table api和streaming使用，以及常见的数据源读写

Language: Java - Size: 60.5 KB - Last synced at: about 18 hours ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

bekisz/flink-pi

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.

Language: Scala - Size: 49.8 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0

nagyf/coinbase-kafka-flink-streaming

This is an example application that streams real-time market data from Coinbase, and uses Apache Flink to process the stream

Language: Java - Size: 6.84 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 0

shaunmcglinchey/tweetpipe-flink-kinesis-consumer

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.

Language: Java - Size: 3.91 KB - Last synced at: 4 months ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

UnconventionalMindset/FlinkJavaSample

Sample Apache Flink Java project.

Language: Java - Size: 10.7 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0

UnconventionalMindset/flink-scala-sample

Sample Apache Flink project in Scala.

Language: Scala - Size: 4.88 KB - Last synced at: about 2 years ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

isaias/data-engineering

Stream processing

Size: 13.7 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0

leetoo/StockMarket Fork of devidaslabade/StockMarket

Language: Scala - Size: 157 KB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 0 - Forks: 0

leetoo/hedge-stocktracker Fork of venkataraoalahari/hedge-stocktracker

Language: Java - Size: 68.4 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0