键控流的输出流在经过与广播流的连接之后，再经过处理函数后，是否仍然是键控流？
浏览 9提问于2020-05-15得票数 0
回答已采纳
从Flink 1.5发布公告中，我们知道Flink现在支持“广播状态”，并描述了“广播状态为Flink的CEP库的”动态模式“特性的实现打开了障碍。”这是否意味着目前我们可以使用“广播状态”来实现“动态模式”而不需要Flink CEP？另外，我不知道在有或没有广播状态的情况下实现Flink CEP的“动态模式”有什么区别？=============
测试广播数据流的</em
浏览 1提问于2018-05-26得票数 0
回答已采纳
我在使用Flink连接两个流的上下文中查看，并希望了解这两个流之间的区别以及影响Flink处理它们的方式。作为一个相关的问题，我还想了解CoProcessFunction与KeyedCoProcessFunction有何不同。
浏览 2提问于2021-02-17得票数 1
回答已采纳
我有一个按键分片事件流的KeyedStream。每个键控流将发出事件，然后需要将这些事件与来自其他键控操作符的所有其他事件重新组合，以形成将以Flink状态存在的单个图。// key input events for processing by key
KeyedStream<MyEvent> keyedStream = myInputStream.keyBy(...
浏览 3提问于2019-07-08得票数 0
2回答
我要求澄清Apache (1.6.0)在通过窗口发送事件并应用了一些操作符(例如减())或process()之后是如何处理来自KeyedStreams的事件的。假设在键控窗口流上的操作符被执行后，单个节点集群是否只剩下1 DataStreams或完全k DataStreams (其中k是键的唯一值数)？要澄清，请考虑从某个源读取事件，按某个k键，将键控事件发送到某个窗口流中，减少事件，然后执行几乎所有其他操作。下面两
浏览 3提问于2018-09-21得票数 4
回答已采纳
2回答
第二种是称为customer流的实际流，它包含每个客户的一些数值。这基本上是基于customerId的键控流。因此，基本上，我正在准备我的实际客户流数据，然后在键控流上应用some rules，并得到计算结果。在这个场景
浏览 13提问于2022-08-05得票数 -1
如何在Flink流中实现反馈循环。换句话说，我如何才能编写一个也是SinkFunction的SourceFunction？一种方法是让ControlStream从卡夫卡和我可以从卡夫卡这样的外部系统读到卡夫卡的话题，这就完成了工作。但是，如果我只想从流的末尾反馈到流的开始，那么使用外部系统似乎很奇怪。
浏览 0提问于2018-05-17得票数 1
回答已采纳
我想知道FLINK是否可以支持我的要求，我已经看了很多文章，但我不确定我的情况是否能解决 "name" : "event2"}ControlSet会给我们指令来
浏览 0提问于2020-07-10得票数 1
我正在使用Apache v1.9.1这甚至可以使用广播和迭代来实现吗？如果没有，是否还有其他方法来实现这一目标？下面是我想要做的事情的粗略伪代码：
IterativeStrea
浏览 6提问于2022-09-08得票数 0
回答已采纳
我有一个Flink程序，它接受两个流，即数据/传感器读数流和警报规则流。我正在广播规则流，并将其连接到数据流以生成动态警报。我已将时间戳&水印分配给数据流，并按原样传递规则流(因为只有在看到新的附加规则/更新时，规则流才会有记录)。但是没有产生警报。当两个流，即一个具有时间戳和水印的流和一个有规则的<
浏览 0提问于2019-08-21得票数 2
回答已采纳
1回答
我被指派在互联网上直播一个可能有5万名用户s的活动，这将是一个广播，所以所有的用户都会看到同样的视频。我的查询将是我的带宽需求，因为没有用户查看该流。我有点困惑&原因是每个用户在广播中都需要一个单独的带宽流吗？在rtmp协议上运行流服务器是否需要类C I
浏览 0提问于2014-02-17得票数 -3
我正在apache flink中做一个项目，我需要调用多个API来实现我的目标。每个API的结果是下一个API工作所必需的。同样，由于我在KeyedStream上这样做，相同的流将同时适用于多个数据。 /------API1---API2----当我执行所有这些
浏览 0提问于2019-05-02得票数 1
1回答
我有几个关于Java套接字编程的问题。
Socket[]连接；//已用i=0到connections.length的所有连接初始化-1跨connectioni发送消息；//链接到输出流的新PrintWriter
这个广播可能是原子的吗或者，在并发环境中是否存在潜力，它们可能
浏览 1提问于2012-10-04得票数 0
回答已采纳
2回答
我正在使用Android上的ExoPlayer播放一个广播音频直播流。使用标准实现，当网络连接丢失时，实时流立即停止播放。是否可以缓冲无线电实况流，以便在没有互联网连接的情况下，流继续播放几秒钟，直到网络连接恢复。音乐应用程序Tunein就有这个功能
浏览 1提问于2017-10-21得票数 1
1回答
在Flink中广播“加入”
、、、、
是否有任何方法，我可以使用广播连接在FLINK与我在火花使用的方式。我正在使用联接，但是数据很大，所以我需要广播连接。
谢谢
浏览 0提问于2019-10-17得票数 0
回答已采纳
我使用BroadcastState在Flink中执行流计算。我为我的工作定义了一个扩展KeyedBroadcastProcessFunction的类。假设我有一个由(user_id, location)键控的流A，以及一个流B，它被广播给所有执行者，以便使用我定义的类处理A中的元素。我知道我可以在这个类中在processBroadcastElement或processElement中注册一个计时器，这样当超时时，我可
浏览 0提问于2019-01-08得票数 1
1回答
我有一条在事件流上应用转换规则(来自广播状态)的管道；当我并行运行广播流和原始流时，流性能确实很好，但是当我执行广播转换性能时，会急剧下降。我怎样才能获得更好的表现。运算符之间传递的数据以byte[]格式传递，数据占用也很小。顶层行显示来自Kafka的流消费事件，底部行显示从另一个主题中消耗的规则。通过这种设置，我可
浏览 7提问于2020-09-10得票数 0
回答已采纳
1回答
我们已经通过使用this sample与ACS (Azure通信服务)进行了群呼服务，但现在我们希望广播该呼叫(通过youtube、twitch等)。不幸的是，ACS不提供这样的功能，所以如果可能的话，我们尝试使用Video Call Recording来捕获流并广播它，但无法实现，因为记录只在呼叫之后出现。那么，有没有办法捕获和广播ACS的群呼事件呢？欢迎任何方法(即使是老生常谈的方法)！另外，现
浏览 10提问于2021-07-05得票数 -1
2回答
录制流式广播到MP3
、、、
他很想录制它们，所以我找到了一个叫CoolRecord的小程序，它可以通过网络播放器录制广播。它工作得很好，但问题是录制是通过声卡完成的，当他使用Skype与孙子孙女交谈时，他总是弄乱声音设置，当下一次录制时，一切都是混乱的……现在，我最近发现，可以在无线电流通过声卡之前捕获它。我在网上搜索了几个收听广播甚至录音的软件，但我找到的所有基于Windows的软件都是在音频流<e
浏览 0提问于2011-12-30得票数 10
回答已采纳
输入广播ID和短时间延迟后，您将在屏幕上看到您的网络摄像头提要。查看控制台，您可以看到与Socket.IO服务器交换了几条消息。查看控制台，您可以看到早期的ICE候选人和提供的详细信息是由Socket.IO服务器发送的，观察者回答说
返回到“广播”选项卡，您可以验证答案是否已接收和处理。它不是“广播”，它只是点对点，一旦建立了一个连接，那么未来的连接就会失败。
浏览 2提问于2017-11-13得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
