没有合适的资源?快使用搜索试试~ 我知道了~
word源码java-playgrounds:为PyFlink提供docker环境和示例
共23个文件
py:10个
word_count_input:2个
txt:2个
需积分: 9 0 下载量 5 浏览量
2021-06-05
22:24:19
上传
评论
收藏 20KB ZIP 举报
温馨提示
word源码java 游乐场 Playgrounds 旨在为用户提供一个快速入门的环境和示例,让用户快速了解 PyFlink 的特性。 Playgrounds 设置环境与 docker-compose 并集成了 PyFlink、Kafka、Python 以方便体验。 当前的 Playgrounds 示例基于最新的 PyFlink (1.13.0)。 用法 请查看有关如何在特定 Flink 版本中使用 PyFlink 的特定分支,因为 PyFlink 仍在积极开发中,并且每个版本中都添加了越来越多的功能。 创建 Docker 镜像 cd image # create docker image docker build --tag pyflink/playgrounds:1.13.0-rc2 . # publish docker image docker push pyflink/playgrounds:1.13.0-rc2 环境设置 安装 。 获取 Docker Compose 配置 git clone https://github.com/pyflink/playgrounds.git
资源推荐
资源详情
资源评论
收起资源包目录
playgrounds-master.zip (23个子文件)
playgrounds-master
image
docker-entrypoint.sh 4KB
Dockerfile 4KB
requirements.txt 249B
examples
table
input
requirements.txt 13B
word_count_input 20B
udf_add_input 3B
1-word_count.py 1004B
2-from_kafka_to_kafka.py 4KB
3-udf_add.py 1KB
6-udf_metrics.py 3KB
5-pandas_udf_add.py 1KB
4-udf_add_with_dependency.py 1KB
sql
sql-client.yaml 347B
java
pom.xml 2KB
src
main
java
BlinkBatchPythonUdfSqlJob.java 1KB
utils
udfs.py 142B
datastream
input
word_count_input 20B
batch
9-data_stream_word_count.py 2KB
11-data_stream_state_access.py 3KB
10-data_stream_process_function.py 2KB
docker-compose.yml 2KB
.gitignore 172B
README.md 8KB
共 23 条
- 1
资源评论
weixin_38740827
- 粉丝: 7
- 资源: 947
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
最新资源
资源上传下载、课程学习等过程中有任何疑问或建议,欢迎提出宝贵意见哦~我们会及时处理!
点击此处反馈
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功