《流程》专题

我正在尝试实现一个OpenDaylight捆绑包，它在流发生变化时接收通知。因此，我实现了DataTreeChangeListener 我错过了什么？完整的代码可在Github上获得 提前感谢！最大值

我正在尝试读取文件中的一行，在喷口中，然后将其发送到螺栓，但我一直收到流关闭错误。我关闭错误还是这里有什么问题？ 这是我遇到的错误： Java语言io。IOException：溪流在周日关闭。nio。反恐精英。StreamDecoder。ensureOpen（StreamDecoder.java:46）在sun上。nio。反恐精英。StreamDecoder。在java上读取（StreamDeco

我已经在JDK 1.8上工作了几天，遇到了一些类似的代码： 现在，对于一直在使用流（）的人来说，它可能看起来既简单又干净，但我找不到实现方法的实际类。 当我说列表时，我有以下问题。流（）： 我从哪里获取？ 他们是如何在不实际“干扰”现有集合的情况下实现它的？（假设他们没有接触它们） 我确实试着浏览了java的文档。util。AbstractCollection和java。util。Abstract

当我在GCP中运行作业时，这工作很好，但如果没有任何更新，它将失败。如果我删除update标志，只要没有正在运行的作业，它就可以正常工作。 是否有一种方法来指定，如果作业存在，则更新它，而不仅仅是开始一个新的作业？

不幸的是，Kafka Flink连接器只支持-csv、json和avro格式。因此，我不得不使用较低级别的API（数据流）。 问题：如果我可以从datastream对象中创建一个表，那么我就可以接受在该表上运行的查询。它将使转换部分无缝和通用。是否可以在数据流对象上运行SQL查询？

我有一个关于在Kinesis流中分片数据的问题。我想在向我的kinesis流发送用户数据时使用一个随机分区键，这样碎片中的数据是均匀分布的。为了使这个问题更简单，我想通过在Flink应用程序中键入用户ID来聚合用户数据。

你好，我正在Kafka会话窗口上工作，非活动时间为5分钟。我想要一些反馈，当达到非活动时间时，会话会因按键而降低。假设我有 （A，1） 记录“A”是键的位置。现在，如果我在5分钟内没有获得任何“A”键记录，则会话将被删除。 我想在会话结束时做一些操作，比如说（值）*2。有没有什么方法可以通过Kafka Stream API实现这一点

null 其中lambda1、2等是条件检查函数，例如 但不知什么原因对我不起作用，也许还有其他方法？正如我从文档(https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html)中了解到的，OutputTag用于创建标记为tag的附加消息。还是我错了？

我在我的活动中实现了一个视图寻呼机，在滚动时，将一组数据加载到适配器并将它们显示在列表视图中。一切正常，但我似乎无法找出如何使其更有效，因为滚动时，视图会冻结，但例如在GMAIL应用程序中，当在电子邮件之间滚动时，滚动是如此平滑。 下面是我正在使用的代码: 活动： 创建时 页面适配器： PagechAngelistener：

假设我有一个实现下面接口的对象列表： 假设我也有一个类，它能够对这些对象进行求和： 我在玩一个自定义收集器，但无法找到一些整洁的解决方案。

如何提供一个在条件不匹配时调用的处理程序？ 如果我有两个处理程序，第一个有条件，第二个没有条件，当第一个条件匹配时，两个处理程序都被调用。我如何避免这种情况？

在Spark流式传输中，是否可以将特定的RDD分区分配给集群中的特定节点（为了数据局部性？） 例如，我得到一个事件流[a，a，a，b，b]，并有一个2节点的Spark集群。 我希望所有的a总是去节点1，所有的b总是去节点2。 谢啦！

我想得到以下数据结构：Map 给定的是一个包含字段als原语（位置、目标、距离）或作为键（位置）加映射（目标）的类。从每个独特的位置，一个人可以瞄准多个目的地（按距离）。 关于第二个代码段：结果应该与第一个代码中的结果相同。唯一的区别是，LocationPair中提供的数据已被进一步处理，因此目的地和距离已被放入其目标地图中。 我知道这一定是可能的，但不知何故，我无法弄清楚如何完成它。上面的流代码

应用程序创建的h264帧被发送到标准输出，在标准输出中，使用ffmpeg将该流重新复用为mp4，并将其传递给服务器，服务器根据请求将其传递给客户端。 这是个好办法吗？这甚至可能创建一个低延迟30fps视频流使用这种方法？