Search *

24 results

apache/flink 1.20.0

Apache Flink

Scala versions: 2.12

sql big-data java flink scala python

24144 1650 275
touk/nussknacker 1.17.0

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

Scala versions: 2.13 2.12

decisioning streaming decision-making low-code big-data automation flink kafka stream-processing scala real-time data-streaming gui decision-engine apache-flink flink-kafka rules-engine lowcode touk

661 66
spotify/featran 0.8.0

A Scala feature transformation library for data science and machine learning

Scala versions: 3.x 2.13 2.12

scio flink ml spark scala xgboost tensorflow scalding data algebird breeze

467 22
lightbend/cloudflow 2.3.2

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

Scala versions: 2.13 2.12

sbt plugins: 1.x

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

321 41
streamnative/pulsar-spark 2.4.5

Spark Connector to read and write with Pulsar

Scala versions: 2.11

structured-streaming apache-spark apache-pulsar flink data-science batch-processing stream-processing spark-sql spark data-processing

113 20
ottogroup/flink-spector 0.9.4

Framework for Apache Flink unit tests

Scala versions: 2.12 2.11

apache-flink flink streaming unit-testing

207 10
sansa-stack/sansa-stack 0.9.5

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

Scala versions: 2.12

rdf apache-spark flink spark semantic-web apache-jena distributed-computing

141 35
nmoncho/helenus 1.6.1

An Apache Cassandra Client for Scala 2 inspired by Anorm and Quill

Scala versions: 2.13 2.12

database reactive-streams reactive cassandra pekko-streams flink scala akka-streams client

33 2
sansa-stack/archived-sansa-query 0.7.1

SANSA Query Layer

Scala versions: 2.11

rdf flink partitioning distributed-computing spark sparql

31 10
sansa-stack/archived-sansa-inference 0.7.1

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

Scala versions: 2.11

flink rdfs spark semantic-web distributed-computing owl reasoning

28 6
sansa-stack/archived-sansa-owl 0.7.1

SANSA Stack OWL (Web Ontology Language) API

Scala versions: 2.11

flink owl spark semantic-web distributed-computing

25 6
nmoncho/helenus3 1.0.0

An Apache Cassandra Client for Scala 3 inspired by Anorm and Quill

Scala versions: 3.x

database reactive-streams reactive cassandra pekko-streams flink scala akka-streams client

10 2
codefeedr/codefeedr 0.1.10

CodeFeedr core infrastructure

Scala versions: 2.12

flink kafka scala stream-processing sbt

10 3
touk/nussknacker-flink-compatibility 1.0.0-nu1.18

Additional code needed for using Nussknacker with different Flink versions

Scala versions: 2.13 2.12

flink scala

3 14
zuinnote/hadoopoffice

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

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

63 1
streamnative/pulsar-flink 1.14.3.4

Elastic data processing with Apache Pulsar and Apache Flink

Scala versions: 2.12 2.11

flink-stream-processing catalog flink data-processing batch-processing sql schema-registry apache-pulsar apache-flink schema stream-processing pulsar flink-connector

278 33
yang69/flink-connector-redis_2.11 1.0

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

Scala versions: 2.11

setex flink-connector-redis flink-connector flink flink-redis

7 1
pravega/flink-connectors 0.13.0

Apache Flink connectors for Pravega.

Scala versions: 2.12

flink pravega stream-processing

96 28
knaufk/flink-junit 0.5

A simple JUnit Rule for Apache Flink

Scala versions: 2.11

junit apache-flink java flink junit-rule

5 2
couchbaselabs/flink-connector-couchbase 0.1.0

Experimental Flink connector for Couchbase.

Scala versions: 2.12

couchbase flink

4 2