共有1个答案
你总是可以做这样的事情：
DataSet<EventOrInvalidRecord> goodAndBadTogether = input.map(new CreateObjectIfPossible())
goodAndBadTogether.filter(new KeepOnlyGood())...
goodAndBadTogether.filter(new KeepOnlyBad())...
在某些情况下，另一个合理的选择是继续使用DataStream API，即使您没有流源。
-
我有2个使用kafka主题创建的流，我正在使用DataStream API加入它们。我希望将连接（应用）的结果发布到另一个kafka主题。我在外部主题中看不到连接的结果。 我确认我向两个源主题发布了正确的数据。不确定哪里出了问题。下面是代码片段， 创建的流如下所示。 流连接使用等于的连接执行，如下所示。 如下所述， 有什么线索吗，哪里出了问题？我可以在拓扑中看到可用的消息，谢谢
-
我正在尝试为ApacheFlink导入ScalaAPI流扩展，如中所述https://ci.apache.org/projects/flink/flink-docs-master/apis/scala_api_extensions.html 但是，我的ScalaIDE抱怨以下消息：对象扩展不是包的成员org.apache.flink.streaming.api.scala 我使用的是scala 2
-
我正在尝试使用Spark数据集API，但在进行简单连接时遇到了一些问题。 假设我有两个带有字段的数据集：，那么在的情况下，我的连接如下所示： 但是，对于数据集，有一个。joinWith方法，但相同的方法不起作用：
-
我正在尝试将表单序列化值发布到控制器（WebAPI自宿主）。我无法理解为什么没有正确绑定NameValueCollection。使用jQuery的客户端： 使用Web API自主机的服务器端： 非常感谢。
-
我正在尝试使用< code > DataSet . writeastext(" file:///path/to/my/file ")将数据集API程序的结果写入一个文件。 但是，该程序不产生任何输出。也不会创建输出文件。这可能是什么原因？
-
安装（下载 这是Flink的默认配置。 关于这里发生了什么事，有什么建议吗？