862 Open source projects that are alternatives of or similar to Streaming Readings

StreamLine - Streaming Analytics

Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.

.NET for Apache® Spark™ makes Apache Spark™ easily accessible to .NET developers.

When Apache Pulsar meets Apache Spark

Schema Registry

C# and F# language binding and extensions to Apache Spark

flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

This repository contains the code base for the Open Stream Processing Benchmark.

Framework for Apache Flink unit tests

Production Ready Data Integration Product, documentation：

SQL-based streaming analytics platform at scale

Wormhole is a SPaaS (Stream Processing as a Service) Platform

Elegant stream processing pipeline written entirely in Golang

Kafka client for functional streams for scala (fs2)

Elastic data processing with Apache Pulsar and Apache Flink

A list about Apache Kafka

Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.

Plot live-stats as graph from ApacheSpark application using Lightning-viz

Custom state store providers for Apache Spark

Massively real-time traffic streaming application

Source code for the Kafka Streams in Action Book

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

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

大数据生态解决方案数据平台：基于大数据、数据平台、微服务、机器学习、商城、自动化运维、DevOps、容器部署平台、数据平台采集、数据平台存储、数据平台计算、数据平台开发、数据平台应用搭建的大数据解决方案。

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

Repository for integration with Apache Kafka

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

Apache Flink connectors for Pravega.

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

Window-Based Hybrid CPU/GPU Stream Processing Engine

seatunnel plugin developing examples.

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

Basic framework utilities to quickly start writing production ready Apache Spark applications

Platform for Situated Intelligence

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.

The streaming database built for IoT data storage and real-time processing in the 5G Era

The Refreshingly Simple Cross-Platform C++ Dataflow / Pipelining / Stream Processing / Reactive Programming Framework

Flexible and efficient data processing engine and an evolution of the popular Scramjet Framework based on node.js. Our Transform Hub was designed specifically for data processing and has its own unique algorithms included.

Real Time Analytics and Data Pipelines based on Spark Streaming

Experiments with Apache Flink.

An umbrella project for multiple implementations of model serving

A Scala API for Apache Beam and Google Cloud Dataflow.

Stream computing platform for bigdata

Data Analysis Using Hadoop/Spark/Storm/ElasticSearch/MachineLearning etc. This is My Daily Notes/Code/Demo. Don't fork, Just star !

大数据生态圈学习

an online learning algorithm library for Storm

A collection of core processing blocks

基于开源Litemall电商项目的大数据项目，包含前端埋点(openresty+lua)、后端埋点；数据仓库(五层)、实时计算和用户画像。大数据平台采用CDH6.3.2(已使用vagrant+ansible脚本化)，同时也包含了Azkaban的workflow。

DataFibers Data Service

酷玩 Spark: Spark 源代码解析、Spark 类库等

The RaftLib C++ library, streaming/dataflow concurrency via C++ iostream-like operators

Apache Pulsar Adapters

Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.

Flink 中文视频课程（持续更新...）

Scala examples for learning to use Spark

An open source framework for building data analytic applications.

Haskell on Apache Spark.