mukess / pyflink-demo
☆29Updated 5 years ago
Alternatives and similar repositories for pyflink-demo:
Users that are interested in pyflink-demo are comparing it to the libraries listed below
- Provide docker environment and examples for PyFlink☆193Updated last year
- example☆66Updated 4 years ago
- 基于 PyFlink 的学习文档,通过一个个小实践,便于大家快速入手 PyFlink☆272Updated 3 years ago
- ☆16Updated 2 years ago
- apache-airflow 系列中文资料 👏 `Star`☆48Updated 3 years ago
- Airflow Dag可视化编辑和管理☆47Updated 2 years ago
- [译] Airflow 中文文档☆213Updated last year
- ☆118Updated last year
- ☆3Updated 3 years ago
- Apache Kylin Python Client Library☆63Updated last year
- Python HDFS client☆93Updated this week
- spark将hdfs数据高性能灌入kafka,然后spark streaming/structured streaming高速消费,关注性能,欢迎提供性能/代码优化建议☆33Updated 5 years ago
- Apache DolphinScheduler Python API, aka PyDolphinscheduler.☆54Updated last month
- Deploy bigdata platform using docker compose. Big data components include hadoop, hive, hbase, presto, flink, es, kafka, etc.☆139Updated 5 months ago
- python ETL framework☆104Updated 3 years ago
- The code of book: Spark Streaming Action☆49Updated 2 years ago
- MaxCompute spark demo for building a runnable application.☆106Updated last month
- A collection of examples using flinks new python API☆244Updated 6 years ago
- ☆42Updated 5 years ago
- Stock analysis MLOps system based on DolphinScheduler☆12Updated 2 years ago
- 基于PySpark库,使用SparkSql连接MYSQL数据库并对数据进行统计分析的基础架构☆14Updated 6 years ago
- 基于SparkMLLib实现的商品推荐功能,包括:基于用户的协同过滤,基于物品的协同过滤,基于ALS交替最小二乘的协同过滤。☆34Updated 6 years ago
- Some useful custom hive udf functions, especial array, json, math, string functions.☆224Updated 7 months ago
- Real-time ETL developed by Flink, data from MySQL to Greenplum. Use canal to parse the MySQL binlog, put it into kafka, use Flink to cons…☆78Updated 11 months ago
- 数据治理、数据质量检核/监控平台(Django+jQuery+MySQL)☆184Updated 2 years ago
- 简单易用的ETL工具☆17Updated 5 years ago
- Python PMML scoring library for PySpark as SparkML Transformer☆22Updated 3 months ago
- Ambari集成Apache Kylin服务(离线部署、可支持HDP2.6+及HDP3.0+)☆37Updated 4 years ago
- ☆15Updated 5 years ago
- 一个基于 fasttext + faiss 的商品内容相关推荐实现,nginx+uwsgi+flask / gunicorn+uvicorn+fastapi 提供api查询接口,增加Spark实现 Ansj+Word2vec+LSH+Phoenix☆51Updated last year