《流利说》专题

有人能帮我做这个吗？

通过stream API，我可以编写一个RichCoFlatMapFunction来接受一个控制流和一个数据流，控制流中包含了启动、停止或改变参数的计算元素，我知道我可以存储当前控制设置的状态，并在处理数据流时检查值。 但是用Flink SQL做类似的事情的方法是什么呢？我不能使用join，因为数据流和控制流不能连接在一起。 我们提出的解决方案是通过应用程序本身存储控件设置。其想法是： > 将控制

我浏览了exoplayer的网站和文档以及Github页面，但我对其解释并不满意。 任何人都可以给我一个提示，你如何通过ExoPlayer播放一个http直播流视频？ 提前道谢。

> OAUTH2服务器使用“authorization_code”授予类型发出带有自动批准的JWT令牌。这有HTML/AngularJS表单来收集用户名/密码。 ui/webfront-使用@enablesso。它的所有endpoint都是经过身份验证的，即它没有任何未经授权的登陆页面/UI/链接，用户可以点击这些页面进入/UAA服务器。因此点击http://localhost:8080会立即将您

我在spring batch中有一份工作，包括一个阅读器、一个处理器和一个写入器。 首先，我想知道这3个组件以什么顺序运行:它们是顺序的(对于commit-interval=1)还是在写入前一个项目之前读取新项目以避免延迟？ 我对此很感兴趣，因为我有以下案例： 我想有一条“装配线”：读- 这意味着在写入前一项之前不读取任何内容。 这东西已经开箱即用了吗？如果没有，我怎么能完成这样的事情？

我正在尝试使用此代码使用代理版本0.10测试kafka流。这只是一个打印主题内容的简单代码。还没什么大不了的！但是，由于某种原因内存不足（VM中的10GB RAM）！代码： 运行火花提交： 不幸的是，结果是： java.lang.OutOfMemoryError：Java堆空间 我假设Kafka每次应该带一小部分数据来避免这个问题，对吗？那么，我做错了什么？

从我对Flink的一点经验来看，我已经注意到，即使我们有按顺序到达的事件，它们也应该在对顺序进行分区之后到达。这里讨论的是：流中记录的排序 所以我有3个问题延伸了上面提到的问题： > 我仍然不清楚keyBy函数后订单丢失的原因。为什么会发生这种情况？ 是否有办法确保即使在分区之后事件的顺序？ 如果我们不创建KeyedStreams，那么每个并行操作符的事件顺序是否有保证？

以下是我的一些疑问： 我有两个不同的流，元素按顺序排列。 1）现在，当我在这些流中的每一个上执行时，会维护顺序吗？（因为这里的每个组都将仅发送给一个任务管理器）我的理解是，记录将是一个组的顺序，在这里纠正我。 2） 在这两个流上执行按键操作后，我正在进行联合分组，以获取匹配和非匹配记录。这里也会维持秩序吗？，因为这也适用于KeyedStream。我正在使用事件时间（EventTime）和上升时间（

我想使用Flink流媒体以低延迟处理市场数据（ 我有一组计算，每个都订阅三个流：缓慢移动的参数数据、股票价格和汇率。 例如。 Params（缓慢滴答：每天一次或两次）： 资源（每秒多次滴答声）： fx（每秒多次滴答声）： 每当任何股票、外汇汇率或参数数据发生变化时，我都想立即计算结果并将其输出为新流。这在逻辑上可以表示为连接： 例如选择价格=（params.strike-asset.spot）*f

我使用的是JavaReactor核心，我有一个反应式的对象。对于Flux的每个对象，我需要进行外部查询，为每个输入返回一个不同的对象。然后需要将新生成的与原始的压缩-因此2 Flux的项目必须同步并以相同的顺序生成。 我只是重复使用相同的流两次，如下所示： 这是正确的方法吗？如果发出错误，如何防止阶段跳过失败的迭代？

我试图开发以下代码，但它不起作用。我想使用apache Flink来延迟时间（在时间戳字段中指定的）与当前日期不同的事件。 样品： > 当前日期：2022-05-06 10:30 事件1[{“user1”：“1”，“user2”：“2”，“timestamp”：“2022-05-06 10:30”}-- 事件2[{“user1”：“1”，“user2”：“2”，“timestamp”：“2022-

我正在尝试创建一个使用EWS服务侦听Exchange room邮箱中的事件的项目。 我们可以通过将邮箱id传递给方法“getUserSettings”来获取组信息。 感谢任何帮助

我们基本上是在使用这里记录的Git流：http://nvie.com/posts/a-successful-git-branching-model/.现在开发人员提出了一些问题： 我们从哪里发布代码到生产？发布/修补程序分支还是主分支 我还有更多问题： 如果发布分支没有变化，为什么我们甚至需要一个？我来自ClearCase世界，我总是有这样的印象，如果没有变化，分支就不需要了。 为什么Git不经常

我偶然发现了一个我无法解决的任务。我不得不修改代码以打印而不是。 我明白为什么要这样印。 我很感激任何帮助。

有一个Merge数据结构，它允许“合并”两个同质流，并忘记出处。 是否存在一个流的代数逐点标记并，它从的流和的流生成的流？