ikucan / pykafarrLinks
A high-performance Python Kafka client. Efficiently from Kafka to Pandas and back.
☆40Updated 6 years ago
Alternatives and similar repositories for pykafarr
Users that are interested in pykafarr are comparing it to the libraries listed below
Sorting:
- Derivatives models written with the Tributary data flow library☆23Updated last month
- Python driver for Timeplus Enterprise or Timeplus Proton☆14Updated 6 months ago
- Function dependencies resolution and execution☆70Updated 4 years ago
- Python stream processing for analytics☆39Updated this week
- SQL on dataframes - pandas and dask☆64Updated 7 years ago
- A consistent table management library in python☆159Updated 2 years ago
- Apache Avro <-> pandas DataFrame☆137Updated 10 months ago
- Pylint plugin for static code analysis on Airflow code☆95Updated 4 years ago
- Pandas ExtensionDType/Array backed by Apache Arrow☆230Updated 2 years ago
- Deploy dask on YARN clusters☆69Updated 9 months ago
- ETLy is an add-on dashboard service on top of Apache Airflow.☆69Updated last year
- DB API 2 interface for Flight SQL with SQLAlchemy extras.☆39Updated 2 months ago
- A Python implementation of Apache Kafka Streams☆310Updated 6 years ago
- A kafka streams client library built on confluent-kafka-python☆67Updated last year
- Dockerized setup for testing code on realistic hadoop clusters☆27Updated 4 years ago
- Dremio Flight connector. Access Dremio using Arrow flight☆40Updated 4 years ago
- python-hll☆18Updated 2 years ago
- SQLAlchemy for Dremio via the ODBC and Flight interface.☆30Updated 10 months ago
- Example for simple Apache Arrow Flight service with Apache Spark and TensorFlow clients☆36Updated 4 years ago
- Jupyter extensions for SWAN☆58Updated last week
- Helpers & syntactic sugar for PySpark.☆62Updated last year
- A Python client for Apache Livy, enabling use of remote Apache Spark clusters.☆70Updated 3 years ago
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- Sample code to accompany blog post showcasing Arrow Flight SQL running on DuckDB☆33Updated 2 years ago
- A python wrapper for the KSQL REST API.☆159Updated last year
- Fast, resilient and reproducible data analysis with cached SQL queries☆30Updated last year
- Python Rest Client to interact against Schema Registry confluent server☆176Updated this week
- Fork of aio-libs/aiokafka☆27Updated last year
- Self-contained demo using PyFlink with Gensim+spaCy to find topics in the Flink User Mailing List. All you need is Docker! 🐳☆10Updated 4 years ago
- Prometheus Exporter for Airflow☆160Updated 11 months ago