BroadcastProcessFunction和CoProcessFunction有什么不同？据我所知，您可以通过它们的帮助来做非常类似的事情我指的是.connect流，并并行处理来自两个流的消息。也就是说，使用CoProcessFunction可以实现Brodcast State的功能。什么时候应该使用广播状态模式，什么时候可以使用纯.connect + CoProcessFunction？
浏览 16提问于2021-03-11得票数 0
回答已采纳
我用BroadcastProcessFunction实现了flink流。在processBroadcastElement中，我得到了我的模型，并将它应用于我在processElement中的事件。下面是我的问题的一个简单的单元测试：import org.apache.flink.streaming.api.functions.co.BroadcastProcessFunctionimp
浏览 0提问于2019-02-13得票数 5
回答已采纳
1回答
Flink广播状态行为
、、、
我试着用一个简单的例子来处理flink的溴化状态。import org.apache.flink.streaming.api.functions.co.BroadcastProcessFunctionimport org.apache.flink.util.Collector
class BroadcastPro
浏览 0提问于2018-06-25得票数 1
回答已采纳
我想读一读州政府的历史。如果状态为null，则读取hbase并更新状态，并使用onTimer设置状态ttl。问题是如何批量读取hbase，因为从hbase读取单个记录的效率不高。
浏览 19提问于2018-08-27得票数 0
下面是我定义的类： import com.snowplowanalytics.snowplow.analytics.scalasdk.Eventimport org.apache.flink.util.Collectorclass MapFunction
浏览 43提问于2021-10-07得票数 0
在引用Flink代码示例时，我观察到当使用connect操作符连接两个流时，coProcessFunction和keyedCoProcessFunction在操作键控流(覆盖processElement1、processElement2和onTimer)时几乎可以互换和相同地扩展，所以当操作键控流时，与keyedCoProcessFunction相比，扩展CoProcessFunction来实现键控连接流的业务逻辑有什么不同
浏览 127提问于2020-09-02得票数 1
回答已采纳
我在使用Flink连接两个流的上下文中查看，并希望了解这两个流之间的区别以及影响Flink处理它们的方式。作为一个相关的问题，我还想了解CoProcessFunction与KeyedCoProcessFunction有何不同。
浏览 2提问于2021-02-17得票数 1
回答已采纳
我有两个要合并的数据流。问题在于，一个数据流的频率比另一个数据流的频率高得多，并且有时一个数据流根本不接收事件。是否可以使用一个流中的最后一个事件，并在即将到来的每个事件中将其与另一个流连接起来？有没有可能对来自一个流或另一个流的每个事件应用连接函数，并维护最后使用的事件的状态，并将此事件用于连接函数？
浏览 6提问于2017-09-02得票数 18
回答已采纳
我只是想了解在Flink中使用CoProcessFunction的用例。举例说明会帮助我更好地理解这个概念。
浏览 21提问于2019-07-28得票数 1
回答已采纳
1回答
在Flink中广播“加入”
、、、、
是否有任何方法，我可以使用广播连接在FLINK与我在火花使用的方式。我正在使用联接，但是数据很大，所以我需要广播连接。
谢谢
浏览 0提问于2019-10-17得票数 0
回答已采纳
我们希望使用Flink来维护窗口聚合，作为事务监视应用程序的一部分。它们将使用滑动窗口定义。例如：“过去5天的现金交易总额”。下面是我需要Flink应用程序做的工作: 1.通过读取历史聚合和构建windows 2来准备事务处理。对于每个新事务: a.用新的事务数据b更新窗口聚合。对我来说，这似乎是某种联接，但我不知道如何在Flink中实现。
我希望有人能用一些简单的代码(甚至是伪代码)来回答，让我开始了解上面数据流的“联接”部分。如果我需要澄清的话请告诉我。
浏览 5提问于2017-06-23得票数 0
我希望对这两个资源(当前逻辑上存储为Flink中的动态表)执行一个连续的联接查询，以便当发生UserProfile更新时，连接表按照与该UserProfile相关联的顺序发出一个one更新的EnrichedOrder因为在Flink中不可能有任意的没有时间窗口的内部联接(大概是因为性能原因)，所以我认为设置过大的时间窗口也是不可能的。
这个用例的推荐方法(Es)是什么？
浏览 0提问于2018-02-02得票数 3
回答已采纳
我试图在ListState中初始化一个“CoProcessFunction”，但是它总是抛出这个错误“java.lang.NullPointerException:键控状态只能在‘键控流’上使用”。这是我使用的代码 new CoProcessFunctionat org.apache.flink.util.Preconditions.checkNotNull(Preconditions.ja
浏览 7提问于2021-03-11得票数 0
回答已采纳
1回答
我在本地和flink集群中运行它，并在集群中取消提交，然后在本地重新运行ProductProcessor
override def p
浏览 4提问于2020-05-08得票数 1
回答已采纳
使用Flink 1.8.1，我尝试将State应用到BroadcastState (使用MapStateDescriptor)，如下所示：
(Holder是包装私有int变量“deger”的POJO )
浏览 1提问于2019-08-09得票数 1
回答已采纳
我正在尝试使用BroadcastState设置一个项目，但由于某些原因，我在尝试运行它时遇到以下错误： org.apache.flink.streaming.runtime.tasks.StreamTaskException:无法序列化运算符对象类org.apache.flink.streaming.api.operators.co.CoBroadcastWithNonKeyedOperator.传入和输出的对象(SampleInput和Token)是非常简单的avro生成的pojos，有两个或三个字段，我试着把BroadcastProcessFun
浏览 58提问于2019-03-13得票数 0
回答已采纳
如何在Flink流中实现反馈循环。换句话说，我如何才能编写一个也是SinkFunction的SourceFunction？
浏览 0提问于2018-05-17得票数 1
回答已采纳
我们正在与flink一起进行异步IO调用。很多时候，IO调用是重复的(相同的参数集)，我们调用的大约80%的API对相同的参数返回相同的响应。所以，我们不想再打电话了。
浏览 7提问于2020-02-03得票数 2
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号