Search *

Page 2 of 35 results

yannick-cw/elastic-indexer4s

Stream your stuff into elasticsearch

Scala versions: 2.12

streaming elasticsearch akka-streams elastic4s scala

18 3
qubole/streaminglens

Qubole Streaminglens tool for tuning Spark Structured Streaming Pipelines

Scala versions: 2.11

micro-batches structured-streaming streaming sparklens cluster-management spark streaming-pipeline scala spark-streaming sla

17 2
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

streaming scala spark-streaming s3 structured-streaming spark sqs

16 2
reactivemongo/reactivemongo-streaming

:leaves: Streaming libraries for ReactiveMongo

Scala versions: 3.x 2.13 2.12 2.11

streaming akka scala mongodb reactivemongo

14 4
qubole/spark-state-store

Rocksdb state storage implementation for Structured Streaming.

Scala versions: 2.11

structured-streaming streaming real-time-processing scalability spark state-management rocksdb performance qubole

16 3
d2a4u/sqs4s

Streaming client for AWS SQS using fs2

Scala versions: 2.13 2.12

aws sqs scala fs2 streaming

12 5
exasol/spark-connector

A connector for Apache Spark to access Exasol

Scala versions: 2.13 2.12 2.11

apache-spark streaming exasol-integration spark connector exasol

13 9
bdoepf/spark-cassandra-sink

spark-cassandra-sink is a Spark Structured Streaming Sink for cassandra

Scala versions: 2.11

cassandra spark streaming structured-streaming

4 0 1
ozancicek/artan

Online latent state estimation with Spark

Scala versions: 2.12 2.11

kalman-filter streaming spark-structured-streaming sparkml pyspark spark python scala finite-mixture

5 1
lhns/fs2-pcap

A library for capturing, crafting, and sending packets with fs2 using pcap4j

Scala versions: 2.13 2.12

pcap4j scala pcap capture packet fs2 streaming

2 4
voidcontext/ghyll

ghyll is a streaming JSON decoder library for Scala

Scala versions: 2.13

cats-effect json-decoding scala cats fs2 streaming

1 1
apache/seatunnel

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.

Scala versions: 2.11

elt cdc high-performance change-data-capture batch apache real-time data-integration offline data-ingestion streaming

7206 260
lhns/fs2-utils

utilities for fs2

Scala versions: 3.x 2.13 2.12

Scala.js versions: 1.x

utils scalajs scala fs2 streaming

0 5
martijnhoekstra/masterleague4s

A scala client for the masterleague API

Scala versions: 2.12

streaming heroes-of-the-storm masterleague client scala asynchronous

0 1
theinnerlight/streaming-kafka

FS2-derived streaming kafka library

Scala versions: 2.12 2.11

kafka scala functional fs2 streaming

0 0 1