Awesome Open Source

Programming Languages

Search results for scala stream

183 search results found

Akka Streams Summary ⭐ 41

Trying to put together some notes I took about Akka-streams and reactive-streams

Scala Dataflow ⭐ 40

Oz-style dataflow (single-assignment) variables and streams for Scala

Rmlstreamer ⭐ 38

The RMLStreamer executes RML rules to generate high quality Linked Data from multiple originally (semi-)structured data sources in a streaming way.

Zio Kinesis ⭐ 38

ZIO-based AWS Kinesis client for Scala

A scala dsl for ssh.

Real Time Stream Processing Engine ⭐ 37

This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

Jawn Fs2 ⭐ 36

Integration between jawn and fs2

Flowing rivers in Minecraft.

Orientdb Scala Stream ⭐ 35

OrientDB scala reactive-streams (akka streams) library for non-blocking and live queries.

Kafka Streams ⭐ 34

Akka.js Examples ⭐ 34

Examples using Akka.js

Kcl Akka Stream ⭐ 33

Kinesis Client Library Akka Stream

Streamcorpus ⭐ 33

common data interchange format for document processing pipelines that apply natural language processing tools to large streams of text

Scala etcd client implementing V3 APIs

Hivemall Spark ⭐ 31

A Hivemall wrapper for Spark

Toketi Iothubreact ⭐ 31

Akka Stream library for Azure IoT Hub

Scalazon ⭐ 31

Idiomatic, opinionated Scala library for AWS

Akka Stream Json ⭐ 30

Akka Streams Workshop ⭐ 30

Code samples (and some text) for the Akka Streams hands-on workshop

Spark As Service Using Embedded Server ⭐ 30

This application comes as Spark2.1-as-Service-Provider using an embedded, Reactive-Streams-based, fully asynchronous HTTP server

Stream Loader ⭐ 30

Components for building stream loaders from Kafka to arbitrary storages

A simple, idiomatic (S)FTP client for ZIO

FunDA, a functional data processing library to supplement FRM (Functional-Relational-Mapper)

Snappy Flows ⭐ 27

Monitor akka applications with reactive streams

Kafka Streams Circe ⭐ 27

Generic Serdes with Circe for Kafka Streams

Akka Streams Interleaving ⭐ 27

Akka Streams example of how to interleave Sources with priorities

Akka_streams_tutorial ⭐ 27

A collection of runnable and self-contained examples inspired by various akka-streams (pekko-streams) and Alpakka (Pekko connectors) docs, tutorials and blogs

Reactivecouchbase Rs Core ⭐ 27

New ReactiveCouchbase driver using reactive-streams

Zpark Ztream ⭐ 27

Driving Spark stream with Scalaz-Stream

Frontroute ⭐ 27

front-end router library for single-page applications built with Scala.js, with an API inspired by Akka HTTP

Twitter Stream Ml ⭐ 26

Machine Learning over Twitter's stream. Using Apache Spark, Web Server and Lightning Graph server.

Thread safe implementation of org.apache.mesos.Scheduler based on scalaz streams

Spark Structured Streaming Examples ⭐ 25

Spark structured streaming examples with using of version 3.4.0

Akka Io Sctp ⭐ 25

Akka I/O driver for SCTP protocol based on Oracle JDK 7/8 support.

Event Sourcing Kafka Streams ⭐ 24

Demo code from my talk @ Codemotion Milan 2018 - "Building event sourced systems with Kafka Streams"

Zio Http4s Examples ⭐ 24

Working through how to do http4s via zio

Kcl Akka Stream ⭐ 23

Custom Akka Stream Sources and Flows to interact with Kinesis streams using Kineis Client Library

Stream Collector ⭐ 23

Collector for cloud-native web, mobile and event analytics, running on AWS and GCP

Kinesis Analytics ⭐ 23

Sample Kinesis application

Redis Streams Zio ⭐ 23

An example application leveraging zio-streams and Redisson library to consume and produce events to Redis streams.

Kafka Streams Plumber ⭐ 22

Plumber, for your dirtiest Kafka streaming jobs

Processing Tweet Stream ⭐ 22

A Processing library for the Twitter Streaming API

Kinesis Example Scala Producer ⭐ 21

Example Scala/SBT event producer for Amazon Kinesis

Akka Streams Example ⭐ 21

Example on Akka Streams with productive cases

Lambda Demo ⭐ 21

Demonstrating Java 8 filter, sort and map functionality with: Java 8 stream/lambda, Google Guava FluentIterable, Kotlin, Groovy, Scala, and by hand

Functional, stream-based CSV processor for Scala

Streamkv ⭐ 21

A streaming key-value store implementation using native Flink Streaming operators

Typesafe Kafka Streams ⭐ 21

A started draft of a typesafe - scala - compatible API

Streamy Db ⭐ 21

Deterministic transactional database layer on top of a stream processing engine

Mapr Sparkml Streaming Uber ⭐ 20

A reactive, non-blocking, asynchronous driver for MongoDB

Scalable Chat ⭐ 20

Sample client-server chat application using Akka Persistence/Cassandra, Akka Cluster, Akka Streams, Akka I/O, and ScalaFX.

Wire Signals ⭐ 20

A small and effective event-handling library for Scala

Getting Started ⭐ 20

Generic regular expression library for Scala using Spire

HTTP/2 server in Scala using Akka Streams

Laminar_cycle ⭐ 18

A cycle.js style user-computer model in Laminar

Redis Kafka Streams State Store

Elastic Indexer4s ⭐ 18

Stream your stuff into elasticsearch

Examples and explanations of how Akka toolkit works

Art Of Stream Processing Workshop ⭐ 18

Acked Stream ⭐ 18

Message Acknowledgement for Akka Streams

Kafka Streams ⭐ 17

Oh you know, just a coupla, two, tree Kafka Streams in Scala

S3 Stream ⭐ 17

Akka Streaming Client for S3 and Supporting Libraries

Torrentstream ⭐ 17

BitTorrent streaming engine, written in Scala and based on akka-streams

Spark Twitter Named Entity ⭐ 16

Named Entity Extraction on Twitter Stream using Apache Spark Streaming and Stanford CoreNLP

Scalanda ⭐ 16

Scala/Akka wrapper for Oanda REST and Stream API

Reactive Streams End To End Example ⭐ 16

A reactive streams end-to-end example in Scala.

Kafka 0.11 Examples ⭐ 16

Code snippets that demonstrate how to leverage the new Kafka 0.11 APIs

Play Iteratees ⭐ 16

Scodec Akka ⭐ 16

Provides interop between scodec and akka

Clickhouse Akka Stream ⭐ 15

Clickhouse sink for akka-streams

Awesome Akka ⭐ 15

Scala akka awesome

Portals is a framework for flexible stateful serverless apps, unifying dataflow streaming with actors

Fs2 Throttler ⭐ 15

Throttling for FS2 based on the Token bucket algorithm.

Kafka Streams Workshop ⭐ 14

Examples and exercises for Kafka Streams workshop

Streams Playground ⭐ 14

Etcd Client ⭐ 14

Scala etc.d client

Kafka Akka Http And Akka Streams Integration ⭐ 14

An example showing how to integrate Apache Kafka with Akka Streams and Akka HTTP.

Kafka S3 Connector ⭐ 14

Freeswitch Scala Esl ⭐ 14

A reactive event socket library for FreeSwitch written using Scala and Akka Streams

Akka Stream Kafka Template.g8 ⭐ 14

Template for Akka Streams & Kafka. Default impl: mirror a topic onto another one

Kafka Streams Scala Examples ⭐ 14

Delimited ⭐ 13

🚀 Simple CSV I/O for Scala. Read, write, validate, and transform. Do so line-by-line, all-at-once, or via streams.

Akka Streams Custom Stream Processing Examples ⭐ 13

Demos of how to do custom stream processing using the Akka Streams GraphStages API

Streamrec ⭐ 13

Building infinite sequences from anonymous functions using tuples and macros.

Spark Http Stream ⭐ 13

spark structured streaming via HTTP communication

Dense Tick File Format ⭐ 13

A proof of concept for an efficient stock price file format based on Akka Streams and Scodec.

Bulkdata ⭐ 13

Bulk data experiments to test Akka streams and related technologies.

Scala Docker ⭐ 13

Docker client for Scala

Akka Streams Kinesis ⭐ 13

Akka Streams connectors for Kinesis

Akvokolekta ⭐ 13

Akka streams extension

Kafka Streams Examples ⭐ 13

Fs2 Mongodb ⭐ 12

Simple streaming interface for FS2 queries

Nyc_taxi_pipeline ⭐ 12

Design/Implement stream/batch architecture on NYC taxi data | #DE

Example Kafkastreams ⭐ 12

Kafka Streams DSL vs Processor API

Kinesis Tee ⭐ 12

Unix tee, but for Kinesis streams

Twitter Realtime Sentiment ⭐ 12

Spark/Cassandra/Akka combo to visualize a cloud of words using d3.js

Related Searches

Javascript Stream (6,703)

Scala Sbt (4,178)

Scala Spark (3,279)

Python Stream (2,326)

Java Stream (2,181)

Scala Akka (2,120)

Java Scala (1,794)

Stream Streaming (1,713)

Scala Play Framework (1,309)

Plugin Scala (1,079)

101-183 of 183 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.