Search *

15 results

apache/hudi

Upserts, Deletes And Incremental Processing on Big Data.

Scala versions: 2.12 2.11

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

4686 378
gearpump/gearpump

Lightweight real-time big data streaming engine over Akka

Scala versions: 2.12 2.11 2.10

akka bigdata scala stream-processing

766 27
touk/nussknacker

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

Scala versions: 2.13 2.12 2.11

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

539 59
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

186 3
akka/akka-stream-contrib

Add-ons to Akka Stream

Scala versions: 2.13 2.12 2.11

akka akka-streams stream-processing

171 1 34
streamnative/pulsar-spark

Spark Connector to read and write with Pulsar

Scala versions: 2.13 2.12 2.11

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

103 19
banno/kafka4s

Functional programming with Kafka and Scala

Scala versions: 2.13 2.12

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

84 15
spinoco/fs2-kafka

Kafka client for functional streams for scala (fs2)

Scala versions: 2.12 2.11

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

79 3
gigahexhq/jetprobe

🚀 Validation DSL for data pipelines

Scala versions: 2.12 2.11

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.12 2.11

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

26 0 2
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: 3.x 2.13

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

2 1
pravega/flink-connectors

Apache Flink connectors for Pravega.

Scala versions: 2.12 2.11

flink pravega stream-processing

94 29
streamnative/pulsar-flink

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

280 33