timbess / flink-statefulfun-hs
Haskell SDK for Flink stateful functions
☆13Updated 3 years ago
Alternatives and similar repositories for flink-statefulfun-hs:
Users that are interested in flink-statefulfun-hs are comparing it to the libraries listed below
- Apache Pulsar client for Haskell☆38Updated 4 years ago
- EtlFlow is an ecosystem of functional libraries in Scala based on ZIO for running complex Auditable workflows which can interact with Goo…☆44Updated 7 months ago
- Purely functional Apache Pulsar client for Scala built on top of Fs2☆71Updated last week
- Apache Pulsar client for Scala with ZIO and ZIO Streams integration.☆23Updated 7 months ago
- Http4s on Finagle Server or Client☆11Updated 3 weeks ago
- ☆36Updated 2 years ago
- All the code from the blog post about exploring STM in ZIO.☆18Updated 5 years ago
- ☆42Updated 5 months ago
- Cooperative multithreading as a pure monad transformer☆73Updated 2 weeks ago
- Streaming Productivity Enhancements for Akka☆24Updated last year
- Bartosz Milewski great book on Category Theory implemented in scala, with property Tests☆33Updated 6 years ago
- A library to support building a coherent set of flink jobs☆17Updated 5 months ago
- A high-performance, purely-functional library for reactive programming based on efficient incremental computation☆24Updated 6 years ago
- ☆11Updated 7 years ago
- Example showing how to create an Akka Cluster on Kubernetes.☆46Updated 11 months ago
- A Kubernetes client for Scala☆125Updated 3 weeks ago
- Scala library for free applicative schemas capable of parsing/rendering sums-of-products data structures.☆108Updated 6 years ago
- Bridge Four is a simple, functional, effectful, single-leader, multi worker, distributed compute system optimized for embarrassingly para…☆37Updated last year
- Enforce best coding practices with ZIO☆82Updated 2 years ago
- ☆9Updated 4 years ago
- A ZIO-based interface to RocksDB.☆32Updated 4 months ago
- Broadcast Kafka messages using web sockets, ZIO playground☆10Updated last year
- Principled, fast, typeclass derivation.☆54Updated last week
- Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde☆24Updated 2 months ago
- Generic protobuf manipulation☆35Updated this week
- Raft algorithm implementation in Scala☆22Updated 2 years ago
- The exercises for the Functional Data Modeling workshop.☆59Updated 4 years ago
- Json/Protobuf convertors for ScalaPB use circe☆45Updated 2 weeks ago
- SchemaRegistry bindings with Avro scheme to use with kafka-client☆16Updated this week
- A REPL for Apache Kafka☆116Updated 4 years ago