回答情况：
提问时间：
问题标签：
PyFlink 请问 pyflink 如何推送数据至clickhouse PyFlink1.15
浏览 134提问于2022-10-13
我是PyFlink的新手。现在，我想将数据推送到mongodb和redis中。那么，如何使用PyFlink向mongodb和redis推送数据呢？
首先感谢您的帮助！
浏览 90提问于2021-06-01得票数 0
我正在使用PyFlink，我想对用Python编写的UDF进行单元测试。要测试以下简单的udf：from pyflink.table import DataTypes
from pyflink.table.udf import/usr/local/anaconda3/envs/pyflink-quickstart/lib/python3.7/site-packages&#
浏览 4修改于2021-03-23得票数 2
回答已采纳
我试着从PyFlink和Kafka开始，但不要出错。python -m pip install apache-flink码ModuleNotFoundError: No module named 'pyFlink'
浏览 3修改于2020-11-04得票数 2
回答已采纳
我运行在PyFlink程序下面(从复制)from pyflink.table import TableConfig, DataTypes, BatchTableEnvironmentfromfrom pyflink.dataset import ExecutionEnviron
浏览 2提问于2021-03-15得票数 2
回答已采纳
我用PyFlink开发了一个单词计数程序。该程序没有抛出任何错误，也没有提供所需的输出。根据代码，程序应该创建一个新的文本文件，但在执行时没有生成任何文件。请帮助，我的代码附在下面。flink.functions.FlatMapFunction import FlatMapFunctionfrom pyflinkimport datastream
from pyflink.common import W
浏览 2修改于2022-01-23得票数 0
我正在尝试通过PyFlink中的自定义UDAF调用外部函数。我使用的函数要求数据在字典对象中。我尝试使用row(t.rowtime, t.b, t.c).cast(schema)来达到这样的效果。from pyflink.common import Rowfrom pyflink.table.expressions import row
浏览 43提问于2021-06-18得票数 1
回答已采纳
版本python -m pip install apache-flinkfrom pyflink.common.serialization import SimpleStringEncoder误差
ModuleNotFoundError: No module named pyflink.common.serialization
浏览 12提问于2020-11-04得票数 0
回答已采纳
Flink Python文档中有pyflink.datastream.MapFunction。同时不存在RichMapFunction。谁能告诉我原因吗？
浏览 16提问于2022-05-05得票数 0
回答已采纳
我有个玩具管道 from pyflink.datastream import StreamExecutionEnvironment
# Create environmentMapFunction，它都会爆炸，说： Caused by: java.io.IOException: Failed to execute the command: python
-c import pyflink;import os;print(os.path.join(os.path.abspath(os.path.dirname(
浏览 213修改于2021-09-20得票数 0
回答已采纳
我想将下面的代码转换成pyflink，然后在pyflink-shell.sh . it中运行它。); env.execute();但我找不到socketTextStream在b_env，bt_env，s_env，st_env
那么，pyflink
浏览 3修改于2022-05-06得票数 2
回答已采纳
有没有任何方法可以使用Rest将PyFlink作业提交到集群？我查看了这个链接，但是没有找到任何与python相关的API。谢谢!
浏览 3提问于2022-02-18得票数 0
\bin\pyflink.bat examples\python\WordCount.pyStarting execution of program
Usage: ./bin/pyflink<2/3>.
浏览 1修改于2020-02-16得票数 1
我使用PyCharm运行简单的pyflink最新1.13示例(它只有两行)。但是get_gateway()方法不起作用。from pyflink.common.serialization import Encoderfrom pyflink.datastream import StreamExecutionEnvironment
from
浏览 4修改于2021-05-21得票数 0
line 37, in word_count File "/usr/local/lib/python3.7/dist-packages/pyflinktable_config.py", line 49, in __init__ File "/usr/local/lib/python3.7/dist-packages&#
浏览 47修改于2021-01-06得票数 0
我正试图在PyFlink项目中编写一个本地包。但我只能通过相对路径导入。喜欢是否可以在导入为PyFlink的env.add_python_file('/path_to_project')项目中的包中使用绝对路径？
浏览 6修改于2021-11-24得票数 0
回答已采纳
Apache Flink的Python SDK (PyFlink)数据流API支持像窗口这样的操作符吗？到目前为止，我所见过的使用PyFlink进行窗口操作的所有示例都使用了Table API。Datastream API确实支持这些操作符，但看起来还不能通过PyFlink使用这些操作符？ 谢谢!
浏览 25提问于2021-03-21得票数 0
回答已采纳
我是Flink的新成员，我发现Flink支持被称为PyFlink的Python。但我不知道在哪里可以找到相关的PyFlink文档或示例？
浏览 0提问于2020-05-26得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号