Apache Flink batch processing examples demonstrating various algorithms and use cases including WordCount, PageRank, KMeans clustering, Connected Components, and graph processing

Apache Flink RabbitMQ connector that provides source and sink functionality for streaming data to and from RabbitMQ message queues with exactly-once processing semantics when checkpointing is enabled

Apache Flink connector for Amazon Kinesis Data Streams that provides both consumer and producer functionality for streaming data integration with AWS Kinesis services

Base classes and utilities for Apache Flink Kafka connectors providing common functionality for stream processing with exactly-once guarantees

Apache Flink Kafka Connector for streaming data integration with Kafka 0.9.x versions

Apache Flink connector for integrating with Apache Kafka 0.8.x message broker systems

Apache Kafka 0.8.x connector for Apache Flink streaming data processing

Apache Flink client library providing APIs and utilities for submitting, monitoring and managing Flink jobs programmatically

Flink Client APIs and utilities for submitting and managing Apache Flink jobs

Apache Flink connector for Elasticsearch 6.x that provides streaming sink functionality

Apache Flink CEP Scala API provides Complex Event Processing capabilities for Scala applications with pattern matching and event stream processing.

Finite key-value map using the Least Recently Used (LRU) algorithm where the most recently used objects are kept in the map while less recently used items are evicted to make room for new ones.

ZIO Test is a featherweight testing library for effectful programs

ZIO Test is a featherweight testing library for effectful programs built on ZIO, providing a comprehensive framework for property-based testing, test composition, and resource-safe test execution.

Security holding package maintained by npm security team to prevent malicious use of the child_process namespace

ZIO is a zero-dependency Scala library for asynchronous and concurrent programming with comprehensive effect system.

Functional, type-safe, composable streaming library built on ZIO's effect system for Scala

Scala Language-Integrated Connection Kit - Advanced database access library for Scala with strongly-typed APIs

Logback integration module for Play Framework that provides logging configuration and colored console output

Akka TestKit - toolkit for testing Actor systems