Search *

apache/flink

Apache Flink

Scala (JVM): 2.10 2.11 2.12

scala java big-data flink

13905 7562 277

interestinglab/waterdrop

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

Scala (JVM): 2.11

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

1034 348 11

spotify/featran

A Scala feature transformation library for data science and machine learning

Scala (JVM): 2.11 2.12 2.13

breeze algebird flink data scala spark scio xgboost scalding ml tensorflow

383 57 16

lightbend/cloudflow

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

Scala (JVM): 2.12 2.13

Sbt: 1.0

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

266 79 35

touk/nussknacker

Process authoring tool for Apache Flink

Scala (JVM): 2.11 2.12

apache-flink marketers touk flink flink-kafka gui

176 48 32

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

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

blockchain flink cryptoledger bigdata bitcoin spark hive hadoop ethereum

103 39 3

sansa-stack/sansa-rdf

SANSA RDF Library

Scala (JVM): 2.11

distributed-computing flink semantic-web spark rdf

67 15 13

SANSA-Stack/SANSA-RDF

SANSA RDF Library

Scala (JVM): 2.11

distributed-computing flink semantic-web spark rdf

46 11 11

pravega/flink-connectors

Apache Flink connectors for Pravega.

Scala (JVM): 2.11 2.12

flink pravega stream-processing

56 43 23

zuinnote/hadoopoffice

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

Scala (JVM): 2.11 2.12

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

39 20 1

sansa-stack/sansa-query

SANSA Query Layer

Scala (JVM): 2.11

distributed-computing sparql flink spark rdf partitioning

28 11 12

sansa-stack/sansa-owl

SANSA Stack OWL (Web Ontology Language) API

Scala (JVM): 2.11

distributed-computing flink semantic-web spark owl

23 3 7

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

rdfs distributed-computing flink semantic-web reasoning spark owl

23 6 5

codefeedr/codefeedr

CodeFeedr core infrastructure

Scala (JVM): 2.12

sbt flink scala kafka stream-processing

7 6 3

knaufk/flink-junit

A simple JUnit Rule for Apache Flink

Scala (JVM): 2.10 2.11

apache-flink java junit junit-rule flink

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

touk/nussknacker

ottogroup/flink-spector

zuinnote/hadoopcryptoledger

sansa-stack/sansa-rdf

SANSA-Stack/SANSA-RDF

pravega/flink-connectors

zuinnote/hadoopoffice

sansa-stack/sansa-query

sansa-stack/sansa-owl

sansa-stack/sansa-inference

codefeedr/codefeedr

knaufk/flink-junit

couchbaselabs/flink-connector-couchbase