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

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

A Scala feature transformation library for data science and machine learning

flink学习笔记

Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.

💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算)；🚀 支持运行过程中增删topic；🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。

Big Data RDF Processing and Analytics Stack built on Apache Spark and Apache Jena http://sansa-stack.github.io/SANSA-Stack/

Spark Connector to read and write with Pulsar

Code and presentation for Strata Model Serving tutorial

A quotation-based Scala DSL for scalable data analysis.

Parameter Server implementation in Apache Flink

基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf

基于flink的用户行为分析

An umbrella project for multiple implementations of model serving

Write ETL using your favorite SQL dialects

seatunnel plugin developing examples.

An Apache Cassandra Client for Scala 2 inspired by Anorm and Quill

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

SANSA Query Layer