epiphanous / flinkrunner
A library to support building a coherent set of flink jobs
☆13Updated 7 months ago
Related projects: ⓘ
- Scala 3.x wrapper for Apache Flink☆49Updated last year
- Flink Scala API is a thin wrapper on top of Flink Java API which support Scala Types for serialisation as well the latest Scala version☆55Updated this week
- Scala ADT support for Apache Flink☆51Updated last month
- EtlFlow is an ecosystem of functional libraries in Scala based on ZIO for running complex Auditable workflows which can interact with Goo…☆43Updated 3 weeks ago
- Type safety for spark columns☆76Updated last week
- A functional wrapper around Spark to make it works with ZIO☆41Updated this week
- A fork of Apache Flink scala bindings for 2.12, 2.13 and 3.x☆20Updated last month
- ☆87Updated 8 months ago
- explore kafka, spark, fs2 and pure functional programming in scala☆30Updated this week
- Purely functional Apache Pulsar client for Scala built on top of Fs2☆72Updated this week
- Optics for Spark DataFrames☆47Updated 3 years ago
- A schema-aware Scala library for data transformation☆85Updated 6 months ago
- A ZIO-based interface to RocksDB.☆32Updated 8 months ago
- A purely functional Cassandra client built on top of the Datastax Java Driver supporting a variety of effect systems like ZIO & Cats-Effe…☆35Updated this week
- Functional programming with Kafka and Scala☆92Updated this week
- ☆35Updated 2 years ago
- Minimal, idiomatic, stream-based Scala interface for key/value store implementations☆56Updated this week
- Reddit-clone demonstrating how larger, DDD-based, event sourced, purely FP application could be implemented in Scala (if requirements wou…☆35Updated last month
- Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.☆60Updated this week
- Typesafe wrapper for Apache Spark DataFrame API☆136Updated 2 months ago
- A Kubernetes client for Scala☆121Updated last month
- The official repository for the Rock the JVM Cats course☆59Updated 2 months ago
- ZIO 2.0 Restful webservice example using zio, zio-http, zio-json, quill, H2, twirl, zio-streams, zio-cache, zio-logging, zio-actors, zio-…☆58Updated 5 months ago
- Build highly concurrent, distributed, and resilient message-driven applications on the JVM☆45Updated last year
- The official repository for the Rock the JVM Flink course☆29Updated 2 years ago
- Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Stream…☆22Updated this week
- Example of http (micro)service in Scala & pekko☆14Updated last month
- A collection of Magnolia add-on modules☆165Updated this week
- Sources, Sinks and Pipelines for channeling data☆32Updated 10 months ago
- Sample hello application using Scala 3 and zio-temporal☆14Updated 3 months ago