ververica/flink-sql-cookbook

The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.

Language: Dockerfile - Size: 14.1 MB - Last synced at: 4 months ago - Pushed at: over 2 years ago - Stars: 879 - Forks: 202

nielsbasjes/yauaa

Yet Another UserAgent Analyzer

Language: Java - Size: 83.4 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 833 - Forks: 139

TouK/nussknacker

Low-code tool for automating actions on real time data | Stream processing for the users.

Language: Scala - Size: 186 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 691 - Forks: 99

GoogleCloudPlatform/flink-on-k8s-operator 📦

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

Language: Go - Size: 1.67 MB - Last synced at: 2 months ago - Pushed at: almost 3 years ago - Stars: 658 - Forks: 266

delta-io/connectors 📦

This library allows Scala and Java-based projects (including Apache Flink, Apache Hive, Apache Beam, and PrestoDB) to read from and write to Delta Lake.

Language: Java - Size: 4.87 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 383 - Forks: 159

alibaba/feathub

FeatHub - A stream-batch unified feature store for real-time machine learning

Language: Python - Size: 4.56 MB - Last synced at: 12 days ago - Pushed at: about 1 year ago - Stars: 333 - Forks: 56

streamnative/pulsar-flink 📦

Elastic data processing with Apache Pulsar and Apache Flink

Language: Java - Size: 2.16 MB - Last synced at: about 2 months ago - Pushed at: over 2 years ago - Stars: 279 - Forks: 120

raystack/dagger

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.

Language: Java - Size: 12 MB - Last synced at: 2 days ago - Pushed at: almost 2 years ago - Stars: 273 - Forks: 41

dbs-leipzig/gradoop

Distributed Temporal Graph Analytics with Apache Flink

Language: Java - Size: 955 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 248 - Forks: 88

knaufk/flink-faker

A data generator source connector for Flink SQL based on data-faker.

Language: Java - Size: 1.81 MB - Last synced at: 1 day ago - Pushed at: almost 2 years ago - Stars: 224 - Forks: 58

FlinkML/flink-tensorflow 📦

flink-tensorflow - TensorFlow support for Apache Flink

Language: Scala - Size: 180 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 218 - Forks: 82

spotify/flink-on-k8s-operator

Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

Language: Go - Size: 3.08 MB - Last synced at: 3 days ago - Pushed at: 10 days ago - Stars: 216 - Forks: 73

Chabane/bigdata-playground

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

Language: TypeScript - Size: 3.08 MB - Last synced at: 2 months ago - Pushed at: over 6 years ago - Stars: 209 - Forks: 74

ottogroup/flink-spector 📦

Framework for Apache Flink unit tests

Language: Java - Size: 749 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 208 - Forks: 59

ing-bank/flink-deployer

A tool that help automate deployment to an Apache Flink cluster

Language: Go - Size: 17.5 MB - Last synced at: 3 months ago - Pushed at: almost 5 years ago - Stars: 149 - Forks: 49

apengda/fiflow

flink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0

Language: Java - Size: 10.6 MB - Last synced at: over 1 year ago - Pushed at: about 3 years ago - Stars: 111 - Forks: 33

josephmachado/beginner_de_project_stream

Simple stream processing pipeline

Language: Python - Size: 5.81 MB - Last synced at: 3 months ago - Pushed at: about 1 year ago - Stars: 100 - Forks: 31

FlinkML/flink-jpmml

flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Flink streaming engine

Language: Scala - Size: 359 KB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 96 - Forks: 30

getindata/dbt-flink-adapter

Adapter for dbt that executes dbt pipelines on Apache Flink

Language: Python - Size: 14 MB - Last synced at: 21 days ago - Pushed at: over 1 year ago - Stars: 95 - Forks: 12

seznam/euphoria

Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.

Language: Java - Size: 3.9 MB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 81 - Forks: 11

streamnative/awesome-pulsar

A curated list of Pulsar tools, integrations and resources.

Size: 11.7 KB - Last synced at: about 2 months ago - Pushed at: over 4 years ago - Stars: 81 - Forks: 9

twalthr/flink-api-examples

Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.

Language: Java - Size: 31.3 KB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 63 - Forks: 20

aws-samples/amazon-kinesis-data-analytics-flink-starter-kit 📦

Amazon Kinesis Data Analytics Flink Starter Kit helps you with the development of Flink Application with Kinesis Stream as a source and Amazon S3 as a sink. This demonstrates the use of Session Window with AggregateFunction.

Language: Java - Size: 88.9 KB - Last synced at: 24 days ago - Pushed at: almost 2 years ago - Stars: 47 - Forks: 15

realtimedatalake/rtdl

rtdl makes it easy to build and maintain a real-time data lake

Language: Go - Size: 62.5 MB - Last synced at: 8 months ago - Pushed at: over 2 years ago - Stars: 45 - Forks: 9

abeltavares/real-time-data-pipeline

📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.

Language: Python - Size: 1010 KB - Last synced at: 2 months ago - Pushed at: 5 months ago - Stars: 43 - Forks: 4

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, and Postgres

Language: Java - Size: 302 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 43 - Forks: 26

ververica/jupyter-vvp

Jupyter Integration for Flink SQL via Ververica Platform

Language: Python - Size: 312 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 42 - Forks: 8

raycad/stream-processing

Stream processing guidelines and examples using Apache Flink and Apache Spark

Language: Java - Size: 3.55 MB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 39 - Forks: 19

kailanyue/SZ-Metro

深圳地铁大数据客流分析系统

Language: Java - Size: 20.6 MB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 39 - Forks: 11

GMAP/DSPBench

a suite of benchmark applications for distributed data stream processing systems

Language: Java - Size: 250 MB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 28 - Forks: 3

build-on-aws/prioritizing-event-processing-with-apache-kafka

Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

Language: Java - Size: 585 KB - Last synced at: about 2 months ago - Pushed at: 7 months ago - Stars: 28 - Forks: 8

garystafford/streaming-sales-generator

Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python

Language: Python - Size: 9.28 MB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 28 - Forks: 11

confluentinc/vscode

Confluent for Visual Studio Code

Language: TypeScript - Size: 52.7 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 26 - Forks: 12

sanderploegsma/flink-k8s

Example Apache Flink cluster on Kubernetes

Language: Kotlin - Size: 58.6 KB - Last synced at: 26 days ago - Pushed at: almost 7 years ago - Stars: 22 - Forks: 15

hey-johnnypark/apache-flink-jdbc-streaming

Sample project for Apache Flink with Streaming Engine and JDBC Sink

Language: Java - Size: 5.86 KB - Last synced at: about 1 year ago - Pushed at: about 8 years ago - Stars: 22 - Forks: 5

O2-Czech-Republic/proxima-platform

The Proxima platform.

Language: Java - Size: 9.4 MB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 21 - Forks: 7

oceanbase/flink-connector-oceanbase

Apache Flink Connectors for OceanBase.

Language: Java - Size: 500 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 21 - Forks: 8

OS-EDU/BigData-Notes

大数据组件学习记录~~

Language: Scala - Size: 5.93 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 21 - Forks: 13

brakmic/TwitterFlink

A simple Twitter-Streaming Application for Apache Flink

Language: Scala - Size: 41 KB - Last synced at: about 23 hours ago - Pushed at: over 9 years ago - Stars: 21 - Forks: 3

cyberdelia/flink-kotlin

Kotlin support for Apache Flink

Language: Kotlin - Size: 256 KB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 20 - Forks: 1

aws-samples/kda-flink-app-autoscaling 📦

This repo demonstrates how to use AWS application auto-scaling to implement custom-scaling in your Kinesis Data Analytics for Apache Flink applications

Language: Python - Size: 31.3 KB - Last synced at: 24 days ago - Pushed at: 4 months ago - Stars: 19 - Forks: 6

StarPlatinumStudio/Flink-SQL-Practice

Flink SQL 实战 -中文博客专栏

Language: Java - Size: 80.9 MB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 18 - Forks: 5

delftdata/stateflow

Prototype which extracts stateful dataflows by analysing Python code.

Language: Python - Size: 3.99 MB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 17 - Forks: 4

elbaulp/DPASF

My MSc on Data Science final project. This is a library for Data Pre-processing Algorithms for Streaming in Flink (DPASF)

Language: Scala - Size: 1.24 MB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 17 - Forks: 3

confluentinc/flink-table-api-python-examples

Python Examples for running Apache Flink® Table API on Confluent Cloud

Language: Python - Size: 58.6 KB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 16 - Forks: 4

gordonmurray/apache_flink_and_docker_compose

Running Apache Flink containers using Docker Compose is a convenient way to get up and running to try out some Flink workloads.

Size: 25 MB - Last synced at: 3 days ago - Pushed at: 3 months ago - Stars: 15 - Forks: 2

AhmetFurkanDEMIR/Flink-Example

Flink Example

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

build-on-aws/real-time-gaming-leaderboard-apache-flink

Example gaming leaderboard application covering streaming ingestion, CDC enrichment, processing and visualisation including demo of advance real-time analytics concepts like late data arrival, exactly-once, dynamic config, archival and on-demand replay

Language: TypeScript - Size: 61.3 MB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 13 - Forks: 9

IshaanAdarsh/MedStream-Analytics

The project leverages Apache Flink, Apache Kafka and Python digital Twin to provide real-time insights into healthcare data, enabling timely interventions and proactive patient care.

Language: Jupyter Notebook - Size: 76.8 MB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 13 - Forks: 4

TNG/flink-connector-email 📦

IMAP / SMTP connectors for Apache Flink®

Language: Java - Size: 270 KB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 13 - Forks: 5

decodableco/dbt-decodable

A dbt adapter for Decodable

Language: Python - Size: 229 KB - Last synced at: 6 days ago - Pushed at: 4 months ago - Stars: 12 - Forks: 4

fabricalab/streaming-flink-file-source

File source operator for Apache Flink

Language: Java - Size: 73.2 KB - Last synced at: almost 2 years ago - Pushed at: almost 5 years ago - Stars: 12 - Forks: 3

confluentinc/flink-table-api-java-examples

Java Examples for running Apache Flink® Table API on Confluent Cloud

Language: Java - Size: 134 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 11 - Forks: 6

beamline/framework

The Beamline streaming process mining framework

Language: Java - Size: 1.18 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 11 - Forks: 3

luigiselmi/flink-kafka-consumer

A consumer of a Kafka topic based on Flink

Language: Java - Size: 480 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 11 - Forks: 9

FIWARE/tutorials.Big-Data-Flink

:blue_book: FIWARE 305: Real-time Processing of Context Data using Apache Flink

Language: Shell - Size: 37.5 MB - Last synced at: about 2 months ago - Pushed at: 2 months ago - Stars: 10 - Forks: 5

airscholar/ApacheFlink-SalesAnalytics

This repository contains an end-to-end data engineering project using Apache Flink, focused on performing sales analytics. The project demonstrates how to ingest, process, and analyze sales data, showcasing the capabilities of Apache Flink for big data processing.

Language: Java - Size: 6.84 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 9

DeathReaper0965/distributed-deeplearning

End to End Distributed Deep Learning Engine, works both with Streaming and Batch Data built using Apache Flink

Language: Java - Size: 278 KB - Last synced at: over 2 years ago - Pushed at: almost 5 years ago - Stars: 10 - Forks: 0

geoHeil/streaming-reference

A reference architecture for streaming data pipeline

Language: Kotlin - Size: 841 KB - Last synced at: over 2 years ago - Pushed at: almost 5 years ago - Stars: 10 - Forks: 2

gordonmurray/apache_flink_and_iceberg

Using Apache Flink to write to s3 in Apache Iceberg format

Size: 115 MB - Last synced at: 3 days ago - Pushed at: over 1 year ago - Stars: 9 - Forks: 5

isopropylcyanide/flink-couchbase-data-sink

A Flink job that reads a Json file (either one-time or continous poll) as its source and dumps it to couchbase as a sink using the asynchronous Couchbase SDK.

Language: Java - Size: 68.4 KB - Last synced at: about 2 months ago - Pushed at: about 4 years ago - Stars: 9 - Forks: 7

gordonmurray/apache_flink_and_paimon

Trying out Apache Paimon with Apache Flink using Docker Compose

Size: 179 MB - Last synced at: 3 days ago - Pushed at: 3 months ago - Stars: 8 - Forks: 3

gAmUssA/uncorking-analytics-with-pinot-kafka-flink

In this full-day training, we will explore the architectures of Apache Kafka, Apache Flink, and Apache Pinot. We will run local clusters of each system, studying the role each plays in a real-time analytics pipeline.

Language: Makefile - Size: 1.35 MB - Last synced at: 3 months ago - Pushed at: 8 months ago - Stars: 8 - Forks: 5

nikosgavalas/ansible-flink

Apache Flink cluster deployment with Ansible

Language: Jinja - Size: 14.6 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 8 - Forks: 3

tj---/iceberg-demo

A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino

Language: Java - Size: 13.7 KB - Last synced at: almost 2 years ago - Pushed at: about 3 years ago - Stars: 8 - Forks: 3

big-data-europe/pilot-sc4-flink-kafka-consumer Fork of luigiselmi/flink-kafka-consumer

Traffic Monitoring

Language: Java - Size: 499 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 8 - Forks: 4

aws-samples/kda-metrics-dashboard

This repository contains a CloudFormation template that you can customize to deploy a sample metrics dashboard for your Kinesis Data Analytics for Apache Flink application.

Language: Java - Size: 242 KB - Last synced at: 24 days ago - Pushed at: 9 months ago - Stars: 7 - Forks: 4

garystafford/flink-kafka-demo

Apache Flink/Apache Kafka streaming data analytics demonstration using Streaming Synthetic Sales Data Generator

Language: Java - Size: 14.2 MB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 7 - Forks: 1

beamsummit/beam-intro-las-vegas-2019 📦

Hands-on "Workshop" Offered on 11 September 2019 at Beam Summit (Las Vegas).

Language: Java - Size: 1.31 MB - Last synced at: over 2 years ago - Pushed at: about 4 years ago - Stars: 7 - Forks: 1

damianhorna/nyc-taxi-flink

Simple big data pipeline

Language: Scala - Size: 5.96 MB - Last synced at: 6 months ago - Pushed at: about 4 years ago - Stars: 7 - Forks: 0

Adsizzlerlabs/mangolaa-streams-processing-flink

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

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

tspannhw/MmFLaNK

Mm FLaNK Stack (MXNet, MiNiFi, Flink, NiFi, Kafka, Kudu) for AI-IoT

Language: Java - Size: 3.79 MB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 6 - Forks: 1

j3-signalroom/apache_flink-kickstarter

Examples of Apache Flink® applications showcasing the DataStream API, Table API in Java and Python, and Flink SQL, featuring AWS, GitHub, Terraform, Streamlit, and Apache Iceberg.

Language: Java - Size: 33.4 MB - Last synced at: 25 days ago - Pushed at: 26 days ago - Stars: 5 - Forks: 0

crate/cratedb-flink-jobs

This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".

Language: Java - Size: 8.48 MB - Last synced at: 20 days ago - Pushed at: 28 days ago - Stars: 5 - Forks: 3

Archisman-Mridha/instagram-clone

Demonstrating fault tolerant distributed systems by building a battle tested Instagram Clone | For educational purposes only

Language: Go - Size: 1.44 MB - Last synced at: about 2 months ago - Pushed at: 2 months ago - Stars: 5 - Forks: 3

ZisisFl/Online-Anomaly-Detection-Root-Cause-Analysis

Master Thesis: Online Anomaly Detection and Root Cause Analysis. A system based on Apache Kafka and Flink

Language: Scala - Size: 167 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 5 - Forks: 3

gordonmurray/apache_flink_paimon_and_seatunnel

Trying out Apache Flink with Apache Paimon and Apache SeaTunnel

Language: Dockerfile - Size: 115 MB - Last synced at: 3 days ago - Pushed at: over 1 year ago - Stars: 5 - Forks: 3

rmetzger/flink-utils

Optional utilities for Apache Flink®

Language: Java - Size: 37.1 KB - Last synced at: 3 days ago - Pushed at: about 3 years ago - Stars: 5 - Forks: 1

jo-jstrm/DBPro-EKF-SLAM

This is our project on implementing an Extended Kalman Filter for Simultaneous Localization and Mapping of a moving car through a distributed streaming engine, in this case Apache Flink.

Language: Java - Size: 41.9 MB - Last synced at: over 1 year ago - Pushed at: almost 5 years ago - Stars: 5 - Forks: 3

ankushs92/apache-flink-aggregations-clickstreams

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

Language: Java - Size: 27.3 KB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 5 - Forks: 4

Ren294/SmartTraffic_Lakehouse_for_HCMC

A Smart Traffic Management System for Ho Chi Minh City, Vietnam leveraging batch and real-time data processing, intuitive dashboards, and monitoring tools to optimize traffic flow, enhance safety, and support sustainable urban mobility through advanced analytics and user-friendly applications.

Language: Python - Size: 163 MB - Last synced at: 3 months ago - Pushed at: 5 months ago - Stars: 4 - Forks: 0

vojay-dev/flitch

Let's learn about Apache Flink and sentiment analysis by building a real-time sentiment analysis streaming application for the Twitch chat.

Language: Java - Size: 1.36 MB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 0

UDC-GAC/BigDEC

Big Data tool for scalable short-read error correction

Language: Java - Size: 3.5 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 0

Cian911/flink-home

Custom made CO2 sensor using data to automate home ventilation system. :mask:

Language: Scala - Size: 16.4 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 4 - Forks: 1

Emptyless/flinksql-mlflow

A flinksql-mlflow-pytorch implementation

Language: Python - Size: 33.2 KB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 0

vvittis/FlinkSampling

Reservoir Sampling for Group-By Queries in Flink Platform. Answering effectively Single Aggregate.

Language: Java - Size: 69.3 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 4 - Forks: 1

twalthr/flink-project-template

Template for an Apache Flink project.

Language: Java - Size: 9.77 KB - Last synced at: about 1 year ago - Pushed at: almost 3 years ago - Stars: 4 - Forks: 1

nlecoy/flink-chart

A Helm chart to install Apache Flink on Kubernetes

Language: Smarty - Size: 12.7 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 4 - Forks: 1

knoldus/Flinkathon

A library having Scala examples for Apache Flink

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

knaufk/flink-junit

A simple JUnit Rule for Apache Flink

Language: Java - Size: 101 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 4 - Forks: 5

mmziyad/flink-ms

Serving layer for large machine learning models on Apache Flink

Language: Java - Size: 540 KB - Last synced at: almost 2 years ago - Pushed at: almost 7 years ago - Stars: 4 - Forks: 3

sb2nov/beam Fork of apache/beam

Mirror of Apache Beam

Language: Java - Size: 40.9 MB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 4 - Forks: 0

PseudoAj/MyInsightRepo

AUTH: Analytics of Utility Things is a platform for ingesting, processing and extracting insights from next billion connected Internet of Things (IoT).

Language: Python - Size: 133 MB - Last synced at: over 2 years ago - Pushed at: over 8 years ago - Stars: 4 - Forks: 3

ev2900/Flink_Late_Arriving_Date_Event_Order

Helps explain how Flink handles late arriving data and the effects on message order

Language: Python - Size: 354 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 3 - Forks: 0

yuhexiong/kafka-data-pipeline-structured-flink-java

Data pipeline from Kafka to Kafka, Doris and Doris to Kafka using Flink Java.

Language: Java - Size: 76.2 KB - Last synced at: 3 months ago - Pushed at: 7 months ago - Stars: 3 - Forks: 0

idealista/flink_role

Ansible role to install Apache Flink

Language: YAML - Size: 64.5 KB - Last synced at: 2 months ago - Pushed at: 11 months ago - Stars: 3 - Forks: 2

Guru107/flinkjobuploadplugin

A maven plugin that will submit the created fat-jar to the apache flink cluster

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

bdoepf/aws-emr-prometheus

Language: HCL - Size: 38.1 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 1

open-datastudio/zeppelin Fork of apache/zeppelin

Zeppelin notebook online

Language: Java - Size: 84.6 MB - Last synced at: over 1 year ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 5

tspannhw/HBase2

Apache HBase 2.0 with Apache NiFi 1.10, Apache Kafka 2.2, Apache Flink 1.9

Size: 14.5 MB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 0