ikucan / pykafarr
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
- Derivatives models written with the Tributary data flow library☆23Updated last week
- A Cookiecutter template for creating Faust projects quickly.☆70Updated 2 years ago
- A consistent table management library in python☆159Updated last year
- A perspective powered, user editable ray dashboard via ray serve☆45Updated 2 weeks ago
- Dremio Flight connector. Access Dremio using Arrow flight☆40Updated 4 years ago
- DB API 2 interface for Flight SQL with SQLAlchemy extras.☆38Updated 3 weeks ago
- Python stream processing for analytics☆37Updated last month
- A python wrapper for the KSQL REST API.☆159Updated last year
- A kafka streams client library built on confluent-kafka-python☆67Updated last year
- SQL on dataframes - pandas and dask☆64Updated 7 years ago
- Dockerized setup for testing code on realistic hadoop clusters☆27Updated 4 years ago
- Function dependencies resolution and execution☆70Updated 4 years ago
- A Python client for Apache Livy, enabling use of remote Apache Spark clusters.☆70Updated 3 years ago
- Deploy dask on YARN clusters☆69Updated 8 months ago
- Example for simple Apache Arrow Flight service with Apache Spark and TensorFlow clients☆36Updated 4 years ago
- Cross Thread Message Pipe☆18Updated 5 years ago
- Python DataFrame with fast insert and appends☆75Updated last week
- Sample code to accompany blog post showcasing Arrow Flight SQL running on DuckDB☆33Updated 2 years ago
- Asynchronous actions for PySpark☆47Updated 3 years ago
- Python driver for Timeplus Enterprise or Timeplus Proton☆14Updated 4 months ago
- A Python implementation of Apache Kafka Streams☆311Updated 6 years ago
- RedisTimeSeries python client☆99Updated 2 years ago
- Python Rest Client to interact against Schema Registry confluent server☆174Updated this week
- Native Kubernetes integration for Dask☆321Updated last week
- MongoDB integrations for Apache Arrow. Export MongoDB documents to numpy array, parquet files, and pandas dataframes in one line of code.☆102Updated this week
- Fast, resilient and reproducible data analysis with cached SQL queries☆30Updated last year
- ☆30Updated 3 years ago
- The sane way of building a data layer in Airflow☆24Updated 5 years ago
- ETLy is an add-on dashboard service on top of Apache Airflow.☆69Updated last year
- SQLAlchemy dialect for Turbodbc☆23Updated 2 weeks ago