-
permutive-engineering/fs2-google-pubsub
Google Cloud Pub/Sub stream-based client built on top of cats-effect, fs2 and http4s.
Scala versions: 3.x 2.13 2.12 -
absaoss/hyperdrive
Extensible streaming ingestion pipeline on top of Apache Spark
Scala versions: 2.12 2.11 -
yannick-cw/elastic-indexer4s
Stream your stuff into elasticsearch
Scala versions: 2.12 -
qubole/streaminglens
Qubole Streaminglens tool for tuning Spark Structured Streaming Pipelines
Scala versions: 2.11 -
qubole/s3-sqs-connector
A library for reading data from Amzon S3 with optimised listing using Amazon SQS using Spark SQL Streaming ( or Structured streaming).
Scala versions: 2.11 -
qubole/spark-state-store
Rocksdb state storage implementation for Structured Streaming.
Scala versions: 2.11 -
exasol/spark-connector
A connector for Apache Spark to access Exasol
Scala versions: 2.13 2.12 2.11 -
ozancicek/artan
Online latent state estimation with Spark
Scala versions: 2.12 2.11 -
assist-iot-sripas/scala-mqtt-wrapper
Scala wrapper for the Pekko Connectors MQTT Streaming library and the Alpakka MQTT Streaming library.
Scala versions: 3.x 2.13 -
voidcontext/ghyll
ghyll is a streaming JSON decoder library for Scala
Scala versions: 2.13 -
martijnhoekstra/masterleague4s
A scala client for the masterleague API
Scala versions: 2.12 -
apache/seatunnel
SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.
Scala versions: 2.11