adform / stream-loader
Components for building stream loaders from Kafka to arbitrary storages
☆33Updated last month
Alternatives and similar repositories for stream-loader:
Users that are interested in stream-loader are comparing it to the libraries listed below
- Spark Connector to read and write with Pulsar☆113Updated 2 months ago
- Utilities for processing Flink checkpoints/savepoints☆74Updated 5 years ago
- Scala + Druid: Scruid. A library that allows you to compose queries in Scala, and parse the result back into typesafe classes.☆115Updated 3 years ago
- Custom state store providers for Apache Spark☆92Updated 2 years ago
- A table schema-less OLAP Analytics Engine for Big Data.☆24Updated 9 months ago
- Data model generator based on Scala case classes☆28Updated 4 years ago
- Jupyter Integration for Flink SQL via Ververica Platform☆42Updated last year
- ☆63Updated 5 months ago
- Flink native Kubernetes Operator is a java based control plane for running Apache Flink native application on Kubernetes.☆53Updated 2 years ago
- Protobuf serialization support for Apache Flink☆20Updated 3 years ago
- Stateful Functions for Apache Flink☆277Updated last year
- Trino Connector for Apache Paimon.☆31Updated last month
- Thoughts on things I find interesting.☆17Updated last month
- Spark ClickHouse Connector build on DataSourceV2 API☆193Updated last month
- ☆23Updated 6 years ago
- Example setup to demonstrate Prometheus integration of Apache Flink☆94Updated this week
- A Spark metrics sink that pushes to InfluxDb☆51Updated 4 years ago
- Apache Calcite Adapter for Apache Kudu☆28Updated 3 months ago
- An embedded job scheduler.☆114Updated 5 months ago
- A temporary home for LinkedIn's changes to Apache Iceberg (incubating)☆62Updated last month
- Clickhouse Scala Client with Reactive Streams support☆113Updated this week
- SparkCube is an open-source project for extremely fast OLAP data analysis. SparkCube is an extension of Apache Spark.☆133Updated last year
- A library to expose more of Apache Spark's metrics system☆146Updated 5 years ago
- An HBase backed Journal for Akka's experimental persistence / event-sourcing☆47Updated 9 years ago
- This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.☆75Updated last year
- Spark Clickhouse Connector☆72Updated 4 years ago
- ☆33Updated 5 months ago
- ☆104Updated last year
- ☆25Updated 3 years ago
- Flink Statefun SDK for Scala with Cats☆12Updated last year