First project with Apache Flink (a framework for distributed stream and batch data processing)

A collection of hands-on Apache Beam exercises for learning data processing, machine learning, and deployment on various runners and platforms.

Project that implements AMS streaming algorithm to compute the number of distinct items and to estimate kth moment given a twitter stream of data.

Experimental stream processing pipeline with anomaly detection.

Mirror of Apache Beam

Query parser extracted from Riemann and ported from Clojure to Node

An application that gathers streaming data from twitter dataset , uses feature selection techniques to extract relevant keywords from a tweet , performs clustering to detect events . It also takes input from user such that window specified by user allows to further perform clustering which in turn uses a forest data structure to achieve it.

BigData analysis using IBM InfoSphere and Hadoop eco system, including MapReduce, Spark and Pig

The Reactive Programming Language

make simple ReactiveX pattern for golang

An implementation of Apache Flink's TypeSerializer for JSON objects

Just a list of stream-processors

Transceiver Framework: A framework for concurrent multi stage processing of data & MDP: An online motif detector and predictor embedded in the transceiver framework.

Tiny goodies for Continuation-Passing-Style functions (OLDER VERSION), use instead the NEWER `cpsfy`

Big Data streaming processing engine

File archiver based on GZIP algorithm

Common stream abstraction and in-memory implementation for streaming data

Reactive stream processing framework

Cache Library in Python

Developers can create lovely visuals from live data streams. EON Spark is the visual representation of live streaming data, the way you would imagine. iOS, Android and web browsers.