Apache Flink的Python SDK (PyFlink)数据流API支持像窗口这样的操作符吗？到目前为止，我所见过的使用PyFlink进行窗口操作的所有示例都使用了Table API。Datastream API确实支持这些操作符，但看起来还不能通过PyFlink使用这些操作符？ 谢谢!
浏览 25提问于2021-03-21得票数 0
回答已采纳
在PyFlink中，是否可以使用DataStream API通过StreamExecutionEnvironment的addSource(.)创建DataStream，然后使用DataStream API对这个数据流执行转换，然后将该流转换为可以使用TableApi在其上执行addSource语句的形式？我有一个由许多不同类型的事件组成的流，所以我想从一个源创建许多不同的数据流，每个数据流<
浏览 6提问于2022-06-23得票数 0
回答已采纳
1回答
我在一个项目中使用PyFlink 1.13，我试图做以下工作：
我使用PyFlink的Table，我的两个表都是使用SQL声明的。我的查询执行如下：
SELECT UserId, Timestamp, my_udf(Data
浏览 2提问于2021-10-29得票数 0
回答已采纳
我希望在Python中使用套接字流作为Flink工作流的输入。例如，这在scala中与socketTextStream()方法一起工作。val = senv.socketTextStream("localhost"，9000，'\n')
我在PyFlink中找不到类似的东西，尽管文档中简短地提到了它。任何帮助都是非常有用的。
浏览 23提问于2022-01-28得票数 0
我已经成功地使用Pyflink表API连接到Kinesis，并处理了数据流。由于需要更低级别的处理，我现在正试图将此表转换为DataStream。我试过遵循这里的示例，，但我得到了错误：我知道这似乎很明显，但将我的代码与示例进行比较，我无法看出我缺少的是什么。我使用的代码是：
f
浏览 13提问于2022-07-04得票数 0
回答已采纳
我试图从DataStream API开始，但是缺少一个模块。Python 3.7.9码ModuleNotFoundError: No module named pyflink.common.serialization
浏览 12提问于2020-11-04得票数 0
回答已采纳
\bin\pyflink.bat examples\python\WordCount.pyStarting execution of program
Usage: ./bin/pyflink<2/3>.
浏览 1提问于2017-10-28得票数 1
2回答
我正试图在PyFlink中的一个窗口上进行一些聚合。我在窗口定义和select中都有一个time属性。from pyflink.table import EnvironmentSettings, TableEnvironment, DataTypesfrom pyflink.table.expressions import col
from pyflink.table.wi
浏览 15提问于2021-06-17得票数 1
Apache Flink 1.11.0 Python表API目录: postgresql 通过Table API抛出UUID数据类型unsupportedOperatorException，从包含UUID数据类型列的postgresql Catalog表中读取和写入数据。如何处理pyFlink中的UUID数据类型？
浏览 26提问于2020-10-18得票数 0
flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。然后，我得到了问题，数据流是混乱的，我不能设置窗口来对数据流中的数据进行排序。环境信息: flink版本1.7.0 总的来说，我希望对没有水印的联合数据流进行排序。
浏览 30提问于2019-01-12得票数 2
我希望使用数据流将数据加载到使用的BigQuery表中，而不是流式处理(对于我们的用例，流式处理的成本太高)。我看到Dataflow SDK内置了对通过BQ流插入数据的支持，但我在Dataflow SDK中找不到任何开箱即用的支持加载作业的功能。以下是一些问题：2)如果我需要自己滚动，有哪些好
浏览 0提问于2015-06-17得票数 3
我尝试使用外部JAR在Pyflink中注册一个Scala UDF，如下所示，但得到下面的错误。/target/scala-2.12/hello_scala_for_flink-assembly-0.1.jar /Users/py-r/opt/anaconda3/envs/venv_pyflink_37/lib/python3.7/site-packages/pyflink/lib/ Pytho
浏览 20提问于2020-10-27得票数 1
回答已采纳
我将程序的源代码从文本文件更改为云发布/订阅，如下所示。我将莎士比亚文件的数据发布到发布/订阅上，它确实可以正确获取，但.groupByKey之后的转换似乎都不起作用。
浏览 2提问于2017-06-19得票数 2
作为一个玩具示例，假设我希望构建一个web应用程序，该应用程序接收带有ID和$ payed的HTTP请求，并以ID在24小时窗口中支付的总额返回响应。，但是否支持/可能创建一个Flink应用程序，其中输入是HTTP请求，输出是对HTTP请求的响应？
如果Flink不支持这一点，是否还会有另一个数据流框架支持这一点？(对于上面的玩具示例，我想有比使用Flink更简单的解决方案，但我的实际使用
浏览 4提问于2020-06-16得票数 0
回答已采纳
我有一个用例，我必须用实时数据连接历史数据，我想使用混合源，它使用存储历史聚合数据的csv文件，并且想加入与实时聚合数据相同的数据，我找不到做同样的例子。我想使用apache的python客户机使用最新版本的v1.17.dev来完成这个任务。任何线索都会受到赞赏。
浏览 12提问于2022-09-25得票数 0
1回答
假设我有一个数据流，其中包含事件时数据。我希望在8毫秒的窗口时间内收集输入数据流，并减少每个窗口数据。timeWindow(Time.milliseconds(8))Point数据流的关键是处理时间的时间戳映射到处理毫秒时间戳的最后但是，数据流可能到达较晚，并进入
浏览 2提问于2018-07-14得票数 1
回答已采纳
我想知道，无论如何，Flink的数据流API是否可以用来从传入的记录中删除重复项(可能是在特定的时间窗口内)，就像Dataset API一样，它提供了一个称为"Distinct“的转换。或者，如果数据集被转换为数据流以便在Flink中进行内部处理，则无论如何都可以将该数据集转换为数据流。
在这方面请帮帮我。提前感谢！干杯!
浏览 1提问于2020-03-05得票数 0
1回答
所以我有一个用PyFlink SQL API编写的简单的聚合作业。该作业从AWS Kinesis读取数据并将结果输出到kinesis。 我很好奇是否可以用pytest对我的流水线进行单元测试？
浏览 35提问于2021-11-12得票数 0
回答已采纳
GCP数据流是否支持使用SOAP调用外部API端点的转换？我找不到任何Apache库直接支持这一需求。如果不是SOAP，我可以通过Apache转换来执行REST标注吗？
浏览 3提问于2022-10-02得票数 0
云服务器
ICP备案
云直播
腾讯会议
实时音视频
腾讯云开发者
