wdm0006 / flink-python-examples
A collection of examples using flinks new python API
☆242Updated 6 years ago
Related projects ⓘ
Alternatives and complementary repositories for flink-python-examples
- Python client for Hadoop® YARN API☆109Updated 2 years ago
- ☆208Updated 8 years ago
- A developer-friendly Python library to interact with Apache HBase☆612Updated 3 months ago
- Provide docker environment and examples for PyFlink☆191Updated last year
- A process that runs in unison with Apache Airflow to control the Scheduler process to ensure High Availability☆232Updated 2 years ago
- API and command line interface for HDFS☆270Updated last month
- A collection of Hive UDFs☆75Updated 4 years ago
- Learn the pyspark API through pictures and simple examples☆168Updated 3 years ago
- Python DB-API client for Presto☆239Updated 11 months ago
- PySpark for Elastic Search☆55Updated 7 years ago
- Structured Streaming Machine Learning example with Spark 2.0☆92Updated 7 years ago
- A plugin to Apache Airflow to allow you to run Spark Submit Commands as an Operator☆75Updated 5 years ago
- Python DB API 2.0 client for Impala and Hive (HiveServer2 protocol)☆731Updated 2 weeks ago
- Spark SQL UDF examples☆56Updated 6 years ago
- A Python connector for Druid☆511Updated 3 months ago
- pyspark-cassandra is a Python port of the awesome @datastax Spark Cassandra connector. Compatible w/ Spark 2.0, 2.1, 2.2, 2.3 and 2.4☆69Updated last month
- A pure Python implementation of Apache Spark's RDD and DStream interfaces.☆262Updated 2 months ago
- A Python MapReduce and HDFS API for Hadoop☆237Updated 10 months ago
- Visualize streaming machine learning in Spark☆176Updated 7 years ago
- Lightweight Azkaban client☆77Updated 4 years ago
- ☆29Updated 5 years ago
- ☆240Updated 3 years ago
- ☆511Updated 2 years ago
- This project combines Apache Spark and Elasticsearch to enable mining & prediction for Elasticsearch.☆209Updated 10 years ago
- Examples of Spark 2.0☆211Updated 3 years ago
- ☆43Updated 7 years ago
- flink-tensorflow - TensorFlow support for Apache Flink☆215Updated 6 years ago
- Hive UDFs for funnel analysis☆84Updated last year