Search *

15 results

apache/hudi

Upserts, Deletes And Incremental Processing on Big Data.

Scala versions: 2.11 2.12

stream-processing data-integration apacheflink apachespark incremental-processing hudi bigdata datalake apachehudi

3878 354
gearpump/gearpump

Lightweight real-time big data streaming engine over Akka

Scala versions: 2.10 2.11 2.12

akka bigdata scala stream-processing

765 0 27
touk/nussknacker

A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.

Scala versions: 2.11 2.12

streaming apache-flink decision-making low-code big-data flink flink-kafka kafka stream-processing scala real-time marketers gui lowcode touk

374 45
akka/akka-stream-contrib

Add-ons to Akka Stream

Scala versions: 2.11 2.12 2.13

akka akka-streams stream-processing

177 33
tomasmikula/libretto

Declarative concurrency and stream processing library for Scala

Scala versions: 3.x

functional-programming session-types resource-safety concurrency declarative-programming expressiveness type-safety stream-processing linear-types

151 2
streamnative/pulsar-spark

When Apache Pulsar meets Apache Spark

Scala versions: 2.11 2.12

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

96 15
spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

Scala versions: 2.11 2.12

fs2-kafka kafka-driver streaming scodec kafka stream-processing scala asynchronous kafka-client

79 3
banno/kafka4s

Functional programming with Kafka and Scala

Scala versions: 2.12 2.13

cats-effect fp kafka stream-processing zio scala cats fs2 functional-programming

77 128 14
gigahexhq/jetprobe

🚀 Validation DSL for data pipelines

Scala versions: 2.11 2.12

bigdata akka scala integration-testing stream-processing akka-actors

25 2
amient/affinity

Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka

Scala versions: 2.11 2.12

distributed-systems restapi stream-processing high-availability akka-http scalability avro kafka

26 3
anicolaspp/minikaf

Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.

Scala versions: 2.12

reactive kafka stream-processing streams scala reactive-programming

10 1
codefeedr/codefeedr

CodeFeedr core infrastructure

Scala versions: 2.12

flink kafka scala stream-processing sbt

10 3
rtyley/line-break-preserving-line-splitting

Scala versions: 2.13 3.x

jvm splitting-text newline-character-sequences stream-processing io-streams linebreaks

4 6 1
streamnative/pulsar-flink

Elastic data processing with Apache Pulsar and Apache Flink

Scala versions: 2.11 2.12

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

277 33
pravega/flink-connectors

Apache Flink connectors for Pravega.

Scala versions: 2.11 2.12

flink pravega stream-processing

93 23 29