我们希望结合使用迭代和异步IO操作符来执行相同事件的顺序API调用。然而，在回答我提出的另一个问题时，有人提到使用数据流进行sing迭代不是一个好主意。
有人能进一步解释一下吗？
浏览 17提问于2020-05-10得票数 0
回答已采纳
谁能把Flink和Spark作为机器学习的平台进行比较呢？对于迭代算法，哪一种可能更好？链接到一般Flink与火花讨论：
浏览 3提问于2015-04-21得票数 27
回答已采纳
flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。然后，我得到了问题，数据流是混乱的，我不能设置窗口来对数据流中的数据进行排序。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案
浏览 30提问于2019-01-12得票数 2
我已经编写了flink作业来使用数据集和数据流api。我已经从相同的main()方法启动了这两个程序，但现在当我将作业提交到flink Dashboard时。只有dataset api程序正在运行，仪表板显示作业已完成，流未被触发，flink仪表板也未显示有关数据流执行的任何内容。但是，当我从eclipse运行时，数据集和数据流api程序都在运行。是否有其他方法可以将作业提交给flink</
浏览 16提问于2017-07-12得票数 1
我想知道，无论如何，Flink的数据流API是否可以用来从传入的记录中删除重复项(可能是在特定的时间窗口内)，就像Dataset API一样，它提供了一个称为"Distinct“的转换。或者，如果数据集被转换为数据流以便在Flink中进行内部处理，则无论如何都可以将该数据集转换为数据流。
在这方面请帮帮我。提前感谢！干杯!
浏览 1提问于2020-03-05得票数 0
我正在尝试将基于Flink 0.10.1的示例迁移到Flink 1.1.1。示例中使用的TaxiRideSource数据流源实现了Flink 1.x不再提供的org.apache.flink.streaming.api.functions.source.EventTimeSourceFunction如何将TaxiRideSource移植到Flink 1.x？
浏览 2提问于2016-09-07得票数 1
回答已采纳
在Flink中的迭代DataStream循环中如何处理时间戳？例如，下面是Flink中一个简单的迭代循环的例子，其中反馈循环与输入流的类型不同： }
iterativeStream.closeWith(com
浏览 1提问于2019-06-08得票数 0
回答已采纳
1回答
flink是否提供了定期从api轮询并从中创建数据流对象以供进一步处理的方法？ 我们目前将消息推送到kafka，并通过kafka阅读。有没有办法通过flink直接轮询api？
浏览 17提问于2019-06-25得票数 0
使用远程功能的Flink 涉及到Flink StateFun集群将计算任务的执行交给通过某种FaaS机制部署的远程员工，例如AWS Lambda。正如所述，AWS lambda受到扩展限制(它们可以扩展的速度和限制)。请注意，并发的Lambda配额适用于帐户，而不是每个单独的lambda函数。在大规模流传输系统中，特别是如果由单个Lambda调用执行的工作相对于在该时段中在数据流<
浏览 9提问于2021-10-18得票数 0
1回答
是否可以在apache代码中调用外部api (RESTful)。如果有可能的话，那我们该怎么做呢？我从简单的java代码调用一个api，它运行良好，但是当我在apache中使用相同的代码时，它会抛出一个异常：
java.io.IOException: Server returned HTTP response
浏览 1提问于2018-04-27得票数 2
我有两个流，一个是Int流，另一个是json .In，json，有一个键，就是一些int .So，我需要通过键比较来过滤json流和其他整数流，所以在Flink中可以吗？
浏览 1提问于2017-04-20得票数 2
回答已采纳
1回答
我使用的是flink 1.9.0，无法导入或获取表文件 我已经尝试导入与之相关的不同SBT def main(args: Array[String]): Unit = { env.execute()
case class Events(locationID: String, temp: Long)
} 我有一个简单的CSVCould not access type SelfResolvingTypeSerializer in object org.apac
浏览 22提问于2019-10-01得票数 0
1回答
我正在做一个项目，在这个项目中我制作了一个flink数据流程序，并将代码的第一次运行转移到了另一个团队，以便他们可以查看它。他们都是大级别的用户，并问我是否有任何缺点或好处切换到使用gradle，而不是在未来的flink项目使用maven。如果你能说出你在flink的经历，那也是有益的。( 1.)是否有“如果flink项目试图切换到gradle、x、y和z无法工作”之类
浏览 1提问于2017-05-09得票数 2
回答已采纳
我希望在给定的键和公共窗口上加入三个或多个数据流或表。但是，我不知道如何正确地编写代码。正式文档给出了下面的示例，但是它只是连接两个数据流，那么如何在给定的键和公共窗口上连接三个或多个数据流？.});
我尝试用公共窗口连接两个数据流，并利用结果数据流将第三个数据流与公共窗口连接起来。然而，当我们将TimeCharacteristic设置为事件时，这三种数据流的事件时间语义似乎会发生变化。===============
浏览 1提问于2018-06-13得票数 2
我们开始使用Apache进行数据流处理。它处理数据，然后更新接收器中的数据库。我们将数据库端点/凭据配置为Flink配置数据(因为我们有标准dev/test/prod设置)，但不幸的是，密码/api-键与所有其他配置数据一起以明文形式显示在Flink配置仪表板中。是否有一种配置flink的方法，以便java代码仍然可以通过 (或类似的)访问敏感密码信息，但敏感数据不会显示在<e
浏览 0提问于2019-09-10得票数 2
每个流事件必须对照“规则集”中的所有记录进行检查，而且每次匹配都会将一个或多个事件生成到接收器数据流中。规则集中的记录数在6位范围内。目前，我们只是将规则加载到本地规则列表中，并在传入的flatMap上使用DataStream。在flatMap中，我们只是迭代一个列表，将每个事件与每个规则进行比较。为了加快迭代速度，我们还可以将列表分成几个批，实质上是创建一个列表列表，并创建一个单独的线程来
浏览 1提问于2018-06-04得票数 0
回答已采纳
我需要开始一个新的项目，我不知道是否火花或Flink会更好。目前，该项目需要微批处理，但以后可能也需要流事件处理。
假设火花是最好的，是否有缺点使用梁代替选择火花/Flink作为跑步者/引擎？Beam是否会增加任何开销，或者在Spark/Flink中缺少某些API/功能？
浏览 2提问于2019-04-29得票数 1
回答已采纳
我在一个长期窗口中使用flink数据流和TumblingEventTimeWindows，在1.9版本中，我可以通过状态处理器api读取保存点中的windowState数据吗？ 谢谢。
浏览 24提问于2019-08-23得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号