Connector between Spark and InfluxDB.
☆23May 19, 2016Updated 9 years ago
Alternatives and similar repositories for reactiveinflux-spark
Users that are interested in reactiveinflux-spark are comparing it to the libraries listed below
Sorting:
- Non-blocking, reactive InfluxDB driver for Scala and Java.☆43May 19, 2016Updated 9 years ago
- Lens combinators for fused-effects.☆17Oct 19, 2020Updated 5 years ago
- Streaming Analytics platform, built with Apache Flink and Kafka☆36Oct 6, 2023Updated 2 years ago
- Code repository for Fast Data Processing Systems with SMACK Stack by Packt☆18Jan 18, 2023Updated 3 years ago
- InfluxDB connector to Apache Spark on top of Chronicler☆29Jul 29, 2024Updated last year
- Some bifunctor IO type classes☆21Jan 14, 2021Updated 5 years ago
- ☆23Oct 8, 2018Updated 7 years ago
- Example code for building your own MemSQL Streamliner Pipelines☆23Apr 18, 2017Updated 8 years ago
- Example how to integrate Esper with Akka in the form of an Akka event bus☆29Jan 27, 2015Updated 11 years ago
- A Scala compiler plugin for magic imports☆27Dec 30, 2017Updated 8 years ago
- How to use Parquet in Flink☆32May 2, 2017Updated 8 years ago
- ☆29Aug 2, 2018Updated 7 years ago
- Sockscode plugin for vscode☆34Dec 20, 2017Updated 8 years ago
- A high-performance Rust CLI tool and library that automatically introspects SQLite databases and generates complete GraphQL APIs with TOM…☆23Aug 30, 2025Updated 6 months ago
- In-memory OLAP SQL server for object storage data.☆14Oct 15, 2025Updated 4 months ago
- ☆10Mar 29, 2023Updated 2 years ago
- Asynchronous InfluxDB client for Scala☆121Aug 23, 2019Updated 6 years ago
- Classes for parallel composition and racing of asynchronous computations☆43Aug 24, 2023Updated 2 years ago
- Kafka delivery semantics in the case of failure depend on how and when offsets are stored. Spark output operations are at-least-once. So …☆37Apr 19, 2017Updated 8 years ago
- fast spark local mode☆35Aug 20, 2018Updated 7 years ago
- Parse data and generate plotting scripts based on plotly.☆11Dec 8, 2025Updated 2 months ago
- ConfigParser class with AES-256 symmetric encryption support☆10Mar 8, 2024Updated last year
- json或SQL语言转为flink或者spark流/批任务☆12Jun 21, 2022Updated 3 years ago
- Package provides java implementation of the latent dirichlet allocation (LDA) for topic modelling☆10May 18, 2017Updated 8 years ago
- Examples of using LMAX Disruptor in a Java program☆10Oct 10, 2018Updated 7 years ago
- 请求spark rest API获取applications，jobs，stages，executors，rdds，streaming，environment等信息提供监控和报警服务☆11Nov 22, 2018Updated 7 years ago
- A demo of Functional Reactive Programming in Purescript☆11May 17, 2018Updated 7 years ago
- Sequence Planner☆12Nov 17, 2017Updated 8 years ago
- The Valuation of Convertible Bonds with Credit Risk (for Honours in Advanced Mathematics of Finance research project, at the University o…☆11Nov 23, 2012Updated 13 years ago
- Crossfilter.js implemented as a mixin for ultra-fast filtering and sorting techniques baked into React.js components.☆13Mar 3, 2015Updated 11 years ago
- The codebase contains the implementation for the paper "An asset subset-constrained minimax optimization framework for online portfolio s…☆11Dec 3, 2024Updated last year
- Proof-carrying code completions in Dafny☆11Apr 4, 2025Updated 11 months ago
- Durability for web streams powered by S2☆22Jan 2, 2026Updated 2 months ago
- Indexed Functors for GHC 7.6☆22Aug 20, 2019Updated 6 years ago
- Forkable repo for entries in Phoenix Phrenzy (https://phoenixphrenzy.com/)☆12Sep 30, 2019Updated 6 years ago
- Helping you select an MV* framework - Todo apps for Backbone.js, Ember.js, AngularJS, and many more☆11Jan 9, 2015Updated 11 years ago
- Google Clone With React ( Hooks + Context API ) and Google Custom Search JSON API ( Programmable Search Engine )☆10Sep 11, 2020Updated 5 years ago
- Streaming effects for PureScript☆16Nov 8, 2021Updated 4 years ago
- Publish-Subscribe Broker for the Constrained Application Protocol (CoAP) in Golang☆13Jan 22, 2016Updated 10 years ago