# Apache Flink
Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink has been designed to run in all common cluster environments, perform computations at in-memory speed and at any scale.
Learn more about Flink at [https://flink.apache.org/](https://flink.apache.org/)
## Python Packaging
This packaging allows you to write Flink programs in Python, but it is currently a very initial version and will change in future versions.
In this initial version only Table API is supported, you can find the documentation at [https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/tableApi.html](https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/tableApi.html)
The tutorial can be found at [https://ci.apache.org/projects/flink/flink-docs-stable/tutorials/python_table_api.html](https://ci.apache.org/projects/flink/flink-docs-stable/tutorials/python_table_api.html)
The auto-generated Python docs can be found at [https://ci.apache.org/projects/flink/flink-docs-stable/api/python/](https://ci.apache.org/projects/flink/flink-docs-stable/api/python/)
## Python Requirements
Apache Flink Python API depends on Py4J (currently version 0.10.8.1), CloudPickle (currently version 1.2.2), python-dateutil(currently version 2.8.0), Apache Beam (currently version 2.23.0) and jsonpickle (currently 1.2).
## Development Notices
### Protobuf Code Generation
Protocol buffer is used in file `flink_fn_execution_pb2.py` and the file is generated from `flink-fn-execution.proto`. Whenever `flink-fn-execution.proto` is updated, please re-generate `flink_fn_execution_pb2.py` by executing:
```
python pyflink/gen_protos.py
```
PyFlink depends on the following libraries to execute the above script:
1. grpcio-tools (>=1.3.5,<=1.14.2)
2. setuptools (>=37.0.0)
3. pip (>=7.1.0)
### Running Test Cases
Currently, we use conda and tox to verify the compatibility of the Flink Python API for multiple versions of Python and will integrate some useful plugins with tox, such as flake8.
We can enter the directory where this README.md file is located and run test cases by executing
```
./dev/lint-python.sh
```
没有合适的资源?快使用搜索试试~ 我知道了~
PyPI 官网下载 | apache-flink-1.12.5.tar.gz
1.该资源内容由用户上传,如若侵权请联系客服进行举报
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
2.虚拟产品一经售出概不退款(资源遇到问题,请及时私信上传者)
版权申诉
5星 · 超过95%的资源 2 下载量 69 浏览量
2022-01-09
02:18:44
上传
评论
收藏 207.22MB GZ 举报
温馨提示
共210个文件
py:97个
sh:25个
jar:21个
资源来自pypi官网。 资源全名:apache-flink-1.12.5.tar.gz
资源推荐
资源详情
资源评论
收起资源包目录
PyPI 官网下载 | apache-flink-1.12.5.tar.gz (210个子文件)
LICENSE.javax.activation 17KB
LICENSE.asm 2KB
LICENSE.automaton 1KB
LICENSE.base64 2KB
pyflink-udf-runner.bat 2KB
LICENSE.bouncycastle 1KB
coder_impl_fast.c 2.12MB
beam_operations_fast.c 797KB
beam_coder_impl_fast.c 433KB
beam_stream.c 312KB
stream.c 226KB
zoo.cfg 1KB
setup.cfg 108B
flink 2KB
LICENSE.google-auth-library-credentials 1KB
LICENSE.grizzled-slf4j 1KB
LICENSE.icu4j 21KB
MANIFEST.in 1KB
LICENSE.influx 1KB
LICENSE.janino 2KB
flink-dist_2.11-1.12.5.jar 108.8MB
flink-table-blink_2.11-1.12.5.jar 38.4MB
flink-python_2.11-1.12.5.jar 35.98MB
flink-table_2.11-1.12.5.jar 34.42MB
flink-shaded-zookeeper-3.4.14.jar 7.35MB
bash-java-utils.jar 1.92MB
log4j-core-2.12.1.jar 1.6MB
flink-metrics-influxdb-1.12.5.jar 956KB
flink-sql-client_2.11-1.12.5.jar 527KB
flink-metrics-datadog-1.12.5.jar 491KB
log4j-api-2.12.1.jar 270KB
flink-metrics-graphite-1.12.5.jar 171KB
flink-json-1.12.5.jar 132KB
flink-metrics-prometheus-1.12.5.jar 98KB
flink-csv-1.12.5.jar 88KB
log4j-1.2-api-2.12.1.jar 66KB
log4j-slf4j-impl-2.12.1.jar 23KB
flink-metrics-jmx-1.12.5.jar 18KB
flink-external-resource-gpu-1.12.5.jar 15KB
flink-metrics-statsd-1.12.5.jar 12KB
flink-metrics-slf4j-1.12.5.jar 10KB
LICENSE.jaxb 17KB
LICENSE.jline 1KB
LICENSE.jsr166y 2KB
LICENSE.jzlib 1KB
LICENSE.kryo 1KB
LICENSE 11KB
masters 15B
README.md 2KB
LICENSE.minlog 1KB
not-zip-safe 1B
NOTICE 88KB
PKG-INFO 3KB
PKG-INFO 3KB
log4j-console.properties 3KB
log4j-cli.properties 3KB
log4j.properties 3KB
log4j-session.properties 2KB
LICENSE.protobuf 2KB
coder_impl_fast.pxd 7KB
beam_stream.pxd 2KB
beam_operations_fast.pxd 2KB
beam_coder_impl_fast.pxd 2KB
stream.pxd 1KB
types.py 110KB
table_environment.py 86KB
flink_fn_execution_pb2.py 86KB
descriptors.py 72KB
data_stream.py 51KB
catalog.py 48KB
expression.py 46KB
table.py 39KB
state_impl.py 36KB
state_backend.py 35KB
stream_execution_environment.py 35KB
execution_config.py 29KB
connectors.py 28KB
typeinfo.py 27KB
beam_coder_impl_slow.py 26KB
functions.py 25KB
functions.py 25KB
udf.py 24KB
operations.py 24KB
aggregate.py 22KB
expressions.py 19KB
coders.py 18KB
table_config.py 17KB
window.py 17KB
serialization.py 16KB
checkpoint_config.py 16KB
operation_utils.py 15KB
beam_coders.py 14KB
setup.py 14KB
base.py 13KB
restart_strategy.py 12KB
table_result.py 11KB
base.py 11KB
configuration.py 9KB
gen_protos.py 9KB
pyflink_gateway_server.py 9KB
共 210 条
- 1
- 2
- 3
资源评论
- 烈焰得立秋2022-08-09简直是宝藏资源,实用价值很高,支持!
挣扎的蓝藻
- 粉丝: 12w+
- 资源: 15万+
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功