如何在 Java 8 中使用 FilterFunction 过滤 XML

Question

我需要使用Filter功能过滤XML文件。我只想显示带有"Count>63"的记录。我使用Spark。现在我的代码只显示带有字母 a 的行数。 可能我应该使用 List，但我不知道如何在 Java 8 中使用它来过滤 XML 文件。因此，我想得到一个标签名称列表(带有 Count>63 的"control"、"arduino"(。

现在我的代码只显示"带有 a 的行"的数量。但是我想得到一个带有 Count>63 的标签名称列表。它将是："控制，arduino，覆盆子pi，运动规划">也许我应该使用拆分。

这是我的XML文件：

<?xml version="1.0" encoding="utf-8"?>
<tags>
<row Id="1" TagName="soccer" Count="7" ExcerptPostId="12371" WikiPostId="12370" />
<row Id="2" TagName="servos" Count="63" ExcerptPostId="186" WikiPostId="185" />
<row Id="3" TagName="control" Count="394" ExcerptPostId="192" WikiPostId="191" />
<row Id="5" TagName="gait" Count="4" ExcerptPostId="12362" WikiPostId="12361" />
<row Id="6" TagName="walk" Count="7" />
<row Id="8" TagName="arduino" Count="401" ExcerptPostId="202" WikiPostId="201" />
<row Id="9" TagName="raspberry-pi" Count="151" ExcerptPostId="307" WikiPostId="306" />
<row Id="10" TagName="motion-planning" Count="104" ExcerptPostId="11370" WikiPostId="11369" />
</tags>

这是我的Java代码：

import org.apache.spark.api.java.function.FilterFunction;
import org.apache.spark.sql.SparkSession;
import org.apache.spark.sql.Dataset;
public class Main {
public static void main(String[] args) {
String someFile = "/home/files/Tags.xml";
SparkSession spark = SparkSession.builder().appName("Simple app").getOrCreate();
Dataset<String> logData = spark.read().textFile(someFile).cache();
ong numAs = logData.filter((FilterFunction<String>) s -> s.contains("a")).count();
System.out.println("Lines with a: " + numAs);
spark.stop();
}
}

提前谢谢你

Answer 1

我的印象是，您正在尝试通过将 XML 视为一系列行来处理 XML，并将其拆分为换行符边界。您不能以这种方式分析 XML - 行尾没有特别的意义。(您谈到"记录"和"行"，但这些在 XML 世界中是毫无意义的概念：您需要考虑元素和属性。通过快速浏览Spark，我没有看到任何XML处理功能。所以在我看来，你好像在工作中使用了错误的工具。