Kafka offset committer for structured streaming query
☆41Feb 15, 2021Updated 5 years ago
Alternatives and similar repositories for spark-sql-kafka-offset-committer
Users that are interested in spark-sql-kafka-offset-committer are comparing it to the libraries listed below. We may earn a commission when you buy through links labeled 'Ad' on this page.
Sorting:
- Rocksdb state storage implementation for Structured Streaming.☆17Oct 21, 2020Updated 5 years ago
- Spark Structured Streaming State Tools☆34Jul 3, 2020Updated 5 years ago
- Qubole Streaminglens tool for tuning Spark Structured Streaming Pipelines☆17Jan 21, 2020Updated 6 years ago
- Custom state store providers for Apache Spark☆92Feb 14, 2025Updated last year
- A java agent for tracing which can be configured via simple text file and instruments the code without rebuilding the project.☆49Feb 28, 2026Updated 2 months ago
- Deploy on Railway without the complexity - Free Credits Offer • AdConnect your repo and Railway handles the rest with instant previews. Quickly provision container image services, databases, and storage volumes.
- elasticsearch7.9 cdh-ext-parcels and single machine multi instance☆10Jul 12, 2021Updated 4 years ago
- Apache Hudi Demo☆21Apr 24, 2025Updated last year
- A library to support building a coherent set of flink jobs☆17Oct 5, 2024Updated last year
- Spark Streaming,Kafka and HBase code accompanying the blog 'Offset Management For Apache Kafka With Apache Spark Streaming'☆23Jun 26, 2017Updated 8 years ago
- Spark package to "plug" holes in data using SQL based rules ⚡️ 🔌☆28May 15, 2020Updated 6 years ago
- flink learning blog. http://www.54tianzhisheng.cn/tags/Flink/☆12Jun 14, 2019Updated 6 years ago
- Ingress data from kafka topic into clickhouse table (JSON format)☆24Apr 12, 2018Updated 8 years ago
- Frequently Asked Questions about PyFlink☆24Mar 1, 2023Updated 3 years ago
- sql实现Structured Streaming☆39Jan 4, 2019Updated 7 years ago
- GPU virtual machines on DigitalOcean Gradient AI • AdGet to production fast with high-performance AMD and NVIDIA GPUs you can spin up in seconds. The definition of operational simplicity.
- 基于 Flink 的 sqlSubmit 程序☆145May 12, 2026Updated 2 weeks ago
- DICOM 공부 내용 정리☆10Mar 20, 2019Updated 7 years ago
- Plugin SBT to Generate Scala classes from Apache Avro schemas hosted on a remote Confluent Schema Registry.☆15Mar 14, 2018Updated 8 years ago
- spring boot demo 是一个用来学习 spring boot 的项目，总共包含 56 个集成demo，已经完成 46 个。包含集成 actuator(监控)、admin(可视化监控)、logback(日志)、aopLog(通过AOP记录web请求日志)、统一异常…☆12Jul 23, 2019Updated 6 years ago
- Files referred to from a blog post about Rabo Alerts☆50Oct 31, 2019Updated 6 years ago
- 跟踪Spark-sql中的字段血缘关系☆21Nov 11, 2024Updated last year
- Big data smart alarm by sql☆12May 11, 2021Updated 5 years ago
- forza-telemetry-kafka-producer☆10May 2, 2022Updated 4 years ago
- Custom datasource about spark structure streaming☆12Jan 29, 2019Updated 7 years ago
- Managed Database hosting by DigitalOcean • AdPostgreSQL, MySQL, MongoDB, Kafka, Valkey, and OpenSearch available. Automatically scale up storage and focus on building your apps.
- A library based on Hudi for Spark.☆10Nov 30, 2021Updated 4 years ago
- Streaming Data Simulator☆17Oct 12, 2020Updated 5 years ago
- Polls sample app for IBM BlueMix PaaS☆14Jun 25, 2014Updated 11 years ago
- hudi-spark-utilities-plus☆11Jul 29, 2022Updated 3 years ago
- Repository containing Docker images for Spark master and slave☆15Nov 3, 2019Updated 6 years ago
- An HBase backed Journal for Akka's experimental persistence / event-sourcing☆47Mar 31, 2015Updated 11 years ago
- Showing the relationship between ImageNet ID and labels and pytorch pre-trained model output ID and labels☆10Oct 11, 2020Updated 5 years ago
- Python Korean Lunar Calendar☆16Sep 14, 2015Updated 10 years ago
- 基于next rsc prisma trpc zod shadcn jotai typescrip等构建的全栈admin starter☆21Dec 31, 2024Updated last year
- Deploy open-source AI quickly and easily - Special Bonus Offer • AdRunpod Hub is built for open source. One-click deployment and autoscaling endpoints without provisioning your own infrastructure.
- Warp Refined is an agentic development environment, born out of the terminal.☆94Updated this week
- Albis: High-Performance File Format for Big Data Systems☆21Jul 12, 2018Updated 7 years ago
- spark学习中文笔记☆13Mar 26, 2019Updated 7 years ago
- REST job server for Apache Spark☆44May 23, 2025Updated last year
- A single Scala file providing bulk-loading for HBase in Spark.☆13Mar 28, 2017Updated 9 years ago
- 智能运维系统后台-微服务实现,采用Nacos+SpringCloud+SpringGateway+Feign+Prometheus+Metis架构☆38Dec 18, 2023Updated 2 years ago
- This project is used for tracking lineage when using spark. Our team is aimed at enhancing the ability of column relation during logical …☆20Jan 7, 2022Updated 4 years ago