Search *

apache/flink

Apache Flink

Scala (JVM): 2.10 2.11 2.12

scala java big-data flink

12915 6946 279

interestinglab/waterdrop

生产环境的海量数据计算产品，文档地址：

Scala (JVM): 2.11

etl-pipeline spark-streaming etl-framework java flink spark sql-engine hadoop

961 323 9

spotify/featran

A Scala feature transformation library for data science and machine learning

Scala (JVM): 2.11 2.12 2.13

scio flink scalding ml scala spark tensorflow data breeze algebird xgboost

355 52 16

lightbend/cloudflow

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

Scala (JVM): 2.12

Sbt: 1.0

streaming-runtimes flink akka streaming-data cloudflow streaming-applications microservices-architectures spark kubernetes

215 58 23

ottogroup/flink-spector

Framework for Apache Flink unit tests

Scala (JVM): 2.10 2.11 2.12

flink streaming unit-testing apache-flink

145 46 10

touk/nussknacker

Process authoring tool for Apache Flink

Scala (JVM): 2.11 2.12

apache-flink flink-kafka flink gui marketers touk

157 49 30

zuinnote/hadoopcryptoledger

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

Scala (JVM): 2.10 2.11

flink bigdata blockchain spark hive hadoop cryptoledger bitcoin ethereum

103 39 3

sansa-stack/sansa-rdf

SANSA RDF Library

Scala (JVM): 2.11

distributed-computing semantic-web flink rdf spark

67 15 13

zuinnote/hadoopoffice

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

Scala (JVM): 2.11 2.12

hadoopoffice poi flink bigdata excel analyze-office-documents spark hive hadoop-ecosystem hadoop office

39 20 1

SANSA-Stack/SANSA-RDF

SANSA RDF Library

Scala (JVM): 2.11

distributed-computing semantic-web flink rdf spark

46 11 11

pravega/flink-connectors

Apache Flink connectors for Pravega.

Scala (JVM): 2.11 2.12

flink pravega stream-processing

49 38 20

sansa-stack/sansa-query

SANSA Query Layer

Scala (JVM): 2.11

distributed-computing flink partitioning rdf spark sparql

28 11 12

sansa-stack/sansa-inference

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

Scala (JVM): 2.11

distributed-computing semantic-web flink reasoning rdfs spark owl

23 6 5

sansa-stack/sansa-owl

SANSA Stack OWL (Web Ontology Language) API

Scala (JVM): 2.11

distributed-computing semantic-web flink spark owl

23 3 7

codefeedr/codefeedr

CodeFeedr core infrastructure

Scala (JVM): 2.12

flink stream-processing kafka sbt scala

7 4 3

knaufk/flink-junit

A simple JUnit Rule for Apache Flink

Scala (JVM): 2.10 2.11

apache-flink java flink junit-rule junit

2 2 2

couchbaselabs/flink-connector-couchbase

Experimental Flink connector for Couchbase.

Scala (JVM): 2.12

couchbase flink

0 0 1

Sorting

Filters

apache/flink

interestinglab/waterdrop

spotify/featran

lightbend/cloudflow

ottogroup/flink-spector

touk/nussknacker

zuinnote/hadoopcryptoledger

sansa-stack/sansa-rdf

zuinnote/hadoopoffice

SANSA-Stack/SANSA-RDF

pravega/flink-connectors

sansa-stack/sansa-query

sansa-stack/sansa-inference

sansa-stack/sansa-owl

codefeedr/codefeedr

knaufk/flink-junit

couchbaselabs/flink-connector-couchbase