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: about 22 hours ago - Pushed at: about 23 hours ago - Stars: 16 - Forks: 4

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: 2 days ago - Pushed at: 2 days ago - Stars: 691 - Forks: 99

Anonymous0-0paper/SWG

AutoPipe: LLM Assisted Automatic Stream Processing Pipeline Generation

Language: Python - Size: 101 KB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 0 - Forks: 0

nielsbasjes/yauaa

Yet Another UserAgent Analyzer

Language: Java - Size: 82.9 MB - Last synced at: 2 days ago - Pushed at: 2 days ago - Stars: 828 - Forks: 139

confluentinc/vscode

Confluent for Visual Studio Code

Language: TypeScript - Size: 51.6 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 26 - Forks: 10

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: 3 days ago - Pushed at: 3 days ago - Stars: 5 - Forks: 0

SonicEXEDVP/real-time-data-pipeline

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

Size: 1000 Bytes - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 1 - Forks: 0

knaufk/flink-faker

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

Language: Java - Size: 1.81 MB - Last synced at: 3 days ago - Pushed at: almost 2 years ago - Stars: 221 - Forks: 59

ev2900/Flink_Late_Arriving_Date_Event_Order

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

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

cyberdelia/flink-kotlin

Kotlin support for Apache Flink

Language: Kotlin - Size: 264 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 20 - Forks: 0

Samir782/poll-it

A modern Reddit-style polling platform to create, vote, and engage with polls using upvotes and downvotes.

Language: TypeScript - Size: 1.05 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 0 - Forks: 0

symphony701/analisis_sentimiento_chat_realtime

This project implements a real-time sentiment analysis pipeline specifically designed for Spanish language YouTube live chat messages.

Language: Shell - Size: 5.31 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 0 - Forks: 0

O2-Czech-Republic/proxima-platform

The Proxima platform.

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

spotify/flink-on-k8s-operator

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

Language: Go - Size: 3.01 MB - Last synced at: 6 days ago - Pushed at: 9 days ago - Stars: 215 - Forks: 73

djdariodiaz/FraudIQ

A modular real-time financial data platform for fraud detection and transaction reconciliation.

Language: Python - Size: 38.1 KB - Last synced at: 20 days ago - Pushed at: 20 days ago - Stars: 0 - Forks: 0

ranjanakarsh/FraudIQ

A modular real-time financial data platform for fraud detection and transaction reconciliation.

Language: Python - Size: 32.2 KB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 0 - Forks: 0

alibaba/feathub

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

Language: Python - Size: 4.56 MB - Last synced at: 21 days ago - Pushed at: about 1 year ago - Stars: 330 - Forks: 55

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: 5 days ago - Pushed at: 2 months ago - Stars: 13 - Forks: 2

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 1 month ago - Pushed at: about 1 month ago - Stars: 11 - Forks: 6

streamnative/awesome-pulsar

A curated list of Pulsar tools, integrations and resources.

Size: 11.7 KB - Last synced at: 29 days ago - Pushed at: over 4 years ago - Stars: 81 - Forks: 9

j3-signalroom/ccaf-housekeeping-python_lib

The CCAF Housekeeping Python Library is a CI/CD support tool designed to automate the teardown of a Flink table and its associated Kafka resources—such as topics and schemas—along with any long-running statements linked to it.

Language: Python - Size: 236 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

mwn-san/confluent-kafka

Kafka CLI Tools, ksqlDB Stream and Table, Confluent Kafka Python Client, Security, Environment Confluent Platform

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

gordonmurray/apache_flink_and_iceberg

Using Apache Flink to write to s3 in Apache Iceberg format

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

yuhexiong/airflow-dag-kafka-flink-doris-python

Language: Python - Size: 43 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 1 - Forks: 0

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 1 month ago - Pushed at: about 2 months ago - Stars: 5 - Forks: 3

getindata/dbt-flink-adapter

Adapter for dbt that executes dbt pipelines on Apache Flink

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

ververica/jupyter-vvp

Jupyter Integration for Flink SQL via Ververica Platform

Language: Python - Size: 312 KB - Last synced at: 13 days ago - Pushed at: almost 2 years ago - Stars: 42 - Forks: 8

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: 4 days ago - Pushed at: almost 2 years ago - Stars: 273 - Forks: 41

avcaliani/hello-flink

🐿️ PoC using Apache Flink.

Language: Java - Size: 277 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 0 - Forks: 0

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: about 1 month ago - Pushed at: 5 months ago - Stars: 43 - Forks: 4

gAmUssA/one-does-not-simply-query-a-stream

WIP demos and code examples for how to query a stream talk

Language: Java - Size: 238 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 1 - Forks: 0

gordonmurray/apache_flink_and_paimon

Trying out Apache Paimon with Apache Flink using Docker Compose

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

josephmachado/beginner_de_project_stream

Simple stream processing pipeline

Language: Python - Size: 5.81 MB - Last synced at: about 2 months ago - Pushed at: 12 months ago - Stars: 100 - Forks: 31

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: about 2 months ago - Pushed at: over 1 year ago - Stars: 43 - Forks: 26

SWEatUNIPD/NearYou

Repository dell'MVP e del PoC prodotto per il progetto di Ingegneria del Software A.A. 2024/25 - UniPD

Language: Java - Size: 91.7 MB - Last synced at: 2 months ago - Pushed at: 2 months ago - Stars: 0 - Forks: 0

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: about 2 months ago - Pushed at: over 1 year ago - Stars: 13 - Forks: 4

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: about 2 months ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 9

kczulko/apache-flink-standalone-docker-cluster

Apache Flink standalone cluster based on docker containers

Language: Shell - Size: 21.5 KB - Last synced at: 2 days ago - Pushed at: about 8 years ago - Stars: 1 - 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: 3 months ago - Pushed at: 3 months ago - Stars: 5 - Forks: 3

AhmetFurkanDEMIR/Flink-Example

Flink Example

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

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: 2 months ago - Pushed at: over 1 year ago - Stars: 63 - Forks: 20

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 1 month ago - Pushed at: 7 months ago - Stars: 28 - Forks: 8

streamnative/pulsar-flink 📦

Elastic data processing with Apache Pulsar and Apache Flink

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

dbs-leipzig/gradoop

Distributed Temporal Graph Analytics with Apache Flink

Language: Java - Size: 942 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 249 - Forks: 88

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: about 1 month ago - Pushed at: over 6 years ago - Stars: 209 - Forks: 74

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: 1 day ago - Pushed at: 4 months ago - Stars: 19 - Forks: 6

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: about 2 months ago - Pushed at: almost 3 years ago - Stars: 658 - Forks: 266

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: about 2 months ago - Pushed at: over 2 years ago - Stars: 81 - Forks: 11

robalaban/flink-playground

Apache Flink ( SQL / DataStream ) Playground

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

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: 3 months ago - Pushed at: over 2 years ago - Stars: 879 - Forks: 202

ing-bank/flink-deployer

A tool that help automate deployment to an Apache Flink cluster

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

decodableco/dbt-decodable

A dbt adapter for Decodable

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

AlessandroConti11/Fault-Tolerant_Data_Flow

This project implements a distributed dataflow platform for processing large amount (big-data) of key-value pairs, where keys and values are integers.

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

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

Soypete/Example_Flink_Plan_Python_Cab

Language: Python - Size: 14.6 KB - Last synced at: 3 months ago - Pushed at: over 6 years ago - Stars: 0 - Forks: 0

dyrnq/cdc-doris

a poc for cdc to doris.

Language: Shell - Size: 21.5 KB - Last synced at: 3 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

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: 2 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0

lmdcma27/DataExpert.io-Boot-Camp

Here i share my practices and solutions for the dataExpert BootCamp. You can follow it in the repo: https://github.com/DataExpert-io/data-engineer-handbook/tree/main/bootcamp/materials

Language: Python - Size: 25.4 KB - Last synced at: about 2 months ago - Pushed at: 4 months ago - Stars: 2 - Forks: 1

oceanbase/flink-connector-oceanbase

Apache Flink Connectors for OceanBase.

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

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: about 2 months ago - Pushed at: 2 months ago - Stars: 13 - Forks: 9

gordonmurray/apache_flink_and_hudi

Using Apache Flink to store data in S3 using Apache Hudi

Size: 133 MB - Last synced at: 5 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

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: about 2 months ago - Pushed at: 5 months ago - Stars: 4 - 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: about 2 months ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0

j3-signalroom/j3-techstack-lexicon

J3's techStack Lexicon.

Size: 259 KB - Last synced at: 2 months ago - Pushed at: 6 months ago - Stars: 0 - Forks: 0

j3-signalroom/linux_flink_with_iceberg

Apache Flink Docker image with Apache Iceberg support for Linux (i.e., non-Mac M chip).

Language: Dockerfile - Size: 21.5 KB - Last synced at: 2 months ago - Pushed at: 6 months ago - Stars: 0 - Forks: 0

j3-signalroom/mac_flink_with_iceberg

Apache Flink Docker image with Apache Iceberg support for Mac M2, M3, or M4 chips.

Language: Dockerfile - Size: 23.4 KB - Last synced at: 2 months ago - Pushed at: 6 months ago - Stars: 0 - Forks: 0

j3-signalroom/supercharge_streamlit-apache_flink

Engaging, interactive visualizations crafted with Streamlit, seamlessly powered by Apache Flink in batch mode to reveal deep insights from data.

Language: Python - Size: 650 KB - Last synced at: 3 months ago - Pushed at: 6 months ago - Stars: 1 - Forks: 0

OS-EDU/BigData-Notes

大数据组件学习记录~~

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

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: about 2 months ago - Pushed at: 7 months ago - Stars: 8 - Forks: 5

gordonmurray/apache_flink_paimon_and_seatunnel

Trying out Apache Flink with Apache Paimon and Apache SeaTunnel

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

Emptyless/flinksql-mlflow

A flinksql-mlflow-pytorch implementation

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

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: 1 day 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: 7 months ago - Pushed at: over 2 years ago - Stars: 45 - Forks: 9

mrsimpson/slides-data-in-motion

Presentation about Event Stream Processing

Language: Vue - Size: 9.23 MB - Last synced at: 6 days ago - Pushed at: 5 months ago - Stars: 0 - Forks: 0

raycad/stream-processing

Stream processing guidelines and examples using Apache Flink and Apache Spark

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

Shixi99/data-streaming-kafk-flink

This is a simple showcase of data streaming using different technologies such as Kafka, Flink, PostgreSQL

Language: Shell - Size: 912 KB - Last synced at: 3 months ago - Pushed at: 9 months ago - Stars: 0 - Forks: 0

JinsYin/flink-connector-mongo

Flink Connector for the MongoDB

Language: Java - Size: 71.3 KB - Last synced at: 3 months ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 0

idealista/flink_role

Ansible role to install Apache Flink

Language: YAML - Size: 64.5 KB - Last synced at: about 1 month ago - Pushed at: 10 months ago - Stars: 3 - Forks: 2

jtzero/asdf-apache

installs packages from https://archive.apache.org/dist/

Language: Shell - Size: 39.1 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 0 - Forks: 1

Abdelhakim-gh/BigData_Project

This project aims to establish a data streaming pipeline with storage, processing, and visualization

Language: Python - Size: 28.7 MB - Last synced at: about 2 months ago - Pushed at: 10 months ago - Stars: 2 - Forks: 0

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 1 month ago - Pushed at: about 4 years ago - Stars: 9 - Forks: 7

twosom/flink-kotlin

The Kotlin code of [Stream Processing with Apache Flink]

Language: Kotlin - Size: 76.2 KB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

HarishHary/blink

Detection engine at scale using Apache Beam, Apache Flink, Kubernetes

Language: Go - Size: 8.13 MB - Last synced at: 6 months ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0

yuhexiong/deploy-flink-gcp-guide

Size: 1.03 MB - Last synced at: 2 months ago - Pushed at: 11 months ago - Stars: 0 - Forks: 0

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 1 month ago - Pushed at: about 1 month ago - Stars: 10 - Forks: 5

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

marceloserpa/big-data-sandbox

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

kanenorman/crypto-streaming

Real time data streaming and analysis

Language: Python - Size: 411 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 1 - Forks: 1

lepetitprinz/apache-flink

Hands-on learning Apache Flink

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

tuhinsharma121/eagleeye

A realtime ingestion and profiling engine for fast data.

Language: Java - Size: 44.9 KB - Last synced at: 9 days ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 1

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

AditModi/realtime-bushfire-alert-with-apache-flink-cep Fork of aws-samples/realtime-bushfire-alert-with-apache-flink-cep

Code and documentation for the demonstration example of the real-time bushfire alerting with the Complex Event Processing (CEP) in Apache Flink on Amazon EMR and a simulated IoT sensor network as described on the AWS Big Data Blog: Real-time bushfire alerting with Complex Event Processing in Apache Flink on Amazon EMR and IoT sensor network.

Size: 19.2 MB - Last synced at: about 1 year ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0

hieuung/Streaming-Kafka

Using various data processing tool for real time data pipeline with Kafka

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

gmarciani/flink-app

Scaffolding for data stream processing applications, leveraging Apache Flink.

Language: Java - Size: 124 KB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 3 - Forks: 0

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

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

psmiraglia/flink-formula

SaltStack formula to install and configure Apache Flink cluster

Language: SaltStack - Size: 42 KB - Last synced at: about 1 year ago - Pushed at: almost 9 years ago - Stars: 0 - Forks: 1

psmiraglia/cloudformation-flink

Setup your own Apache Flink cluster on AWS with CloudFormation

Language: Python - Size: 52.7 KB - Last synced at: about 1 year ago - Pushed at: almost 9 years ago - Stars: 1 - Forks: 0

sanderploegsma/flink-k8s

Example Apache Flink cluster on Kubernetes

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

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: 2 months ago - Pushed at: about 1 year ago - Stars: 4 - Forks: 0