apache/flink

Apache Flink

spotify/featran

A Scala feature transformation library for data science and machine learning

touk/nussknacker

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

lightbend/cloudflow

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

streamnative/pulsar-spark

Spark Connector to read and write with Pulsar

ottogroup/flink-spector

Framework for Apache Flink unit tests

sansa-stack/sansa-stack

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

sansa-stack/archived-sansa-query

SANSA Query Layer

sansa-stack/archived-sansa-inference

A general Inference API based on two of the most popular Big Data processing engines: Apache Spark and Apache Flink

sansa-stack/archived-sansa-owl

SANSA Stack OWL (Web Ontology Language) API

codefeedr/codefeedr

CodeFeedr core infrastructure

zuinnote/hadoopoffice

HadoopOffice - Analyze Office documents using the Hadoop ecosystem (Spark/Flink/Hive)

couchbaselabs/flink-connector-couchbase

Experimental Flink connector for Couchbase.

pravega/flink-connectors

Apache Flink connectors for Pravega.

streamnative/pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink

alibaba/alink

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

knaufk/flink-junit

A simple JUnit Rule for Apache Flink

apache/flink-connector-cassandra

Apache flink

yang69/flink-connector-redis_2.11

forked from org.apache.bahir:flink-connector-redis_2.11:1.0

zuinnote/hadoopcryptoledger

Hadoop Crypto Ledger - Analyzing CryptoLedgers, such as Bitcoin Blockchain, on Big Data platforms, such as Hadoop/Spark/Flink/Hive