《交流群》专题

如果spark streaming在10秒的批处理间隔中获得50行消息，并且在40.5行消息之后，这10秒就结束了，剩下的时间落入另一个10秒的间隔中，前40.5行的文本是一个RDD被首先处理，在我的用例中，前40行是有意义的，但是下一个。5行没有意义，第二个RDD首先也是这样。5行，我的问题是否有效？。请提供建议如何处理这个问题？。 谢谢比尔。

批处理查询中似乎不支持“最新”。我想知道是否有可能用另一种方法做类似的事情（不直接处理偏移）

我创建了一个Akka流，它有一个简单的，和。有了这个，我可以很容易地通过它发送元素。现在我想更改这个流，以便返回一个。根据我想更改。 有可能创造出这样的建筑吗？

我想要一个以给定的时间间隔计算函数并发出其输出的源。作为一种变通方法，我可以通过，但还没有找到更干净的方法。理想情况下，我会有 有什么想法吗？

这看起来不可思议，但我找不到源代码存储库。主github repo包含一个akka stream dir，但不包含当前的发布源。 目前，我设法通过发布：http://search.maven.org/remotecontent?filepath=com/typesafe/akka/akka-stream-experimental_2.11/2.0.1/akka-stream-experimenta

看看这段代码：（这是工作代码，但我不喜欢使用2行，所以寻找我如何使它更好） 我想不出如何在中使用条件来从中删除两个特定元素，因为这会给我带来编译时错误（在IDE中），我最终使用了上面的两个。我会错过什么？ 在运行时不工作（它不筛选） 带有注释代码的整个代码（我试过）供参考

我正在尝试实现一个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：