flink 解析xml文件输出流

在 Flink 中解析 XML 文件可以使用 `XmlInputFormat`，它可以将 XML 文件解析成 `Tuple2<String, XmlElement>` 的形式。

以下是一个示例代码，演示如何读取 XML 文件，并将其中的数据输出到流中：

import org.apache.flink.api.common.functions.FlatMapFunction;
import org.apache.flink.api.java.ExecutionEnvironment;
import org.apache.flink.api.java.io.XmlInputFormat;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.core.fs.FileSystem;
import org.apache.flink.util.Collector;
import org.w3c.dom.Element;

public class XmlParserExample {

    public static void main(String[] args) throws Exception {

        ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

        XmlInputFormat inputFormat = new XmlInputFormat();
        inputFormat.setFilePath("path/to/xml/file");
        inputFormat.setRecordElementName("record");

        env.createInput(inputFormat)
           .flatMap(new FlatMapFunction<Tuple2<String, Element>, String>() {
               @Override
               public void flatMap(Tuple2<String, Element> value, Collector<String> out) throws Exception {
                   // 解析 XML 文件中的数据，并输出到流中
                   String name = value.f1.getElementsByTagName("name").item(0).getTextContent();
                   String age = value.f1.getElementsByTagName("age").item(0).getTextContent();
                   out.collect(name + "," + age);
               }
           })
           .writeAsText("path/to/output/file", FileSystem.WriteMode.OVERWRITE);

        env.execute("XML Parser Example");
    }
}

在上述代码中，我们使用 `XmlInputFormat` 读取 XML 文件，并指定了 XML 元素的名称为 `record`。然后，我们使用 `flatMap` 函数解析 XML 文件中的数据，并将其输出到流中。最后，我们使用 `writeAsText` 将结果写入到指定的文件中。

需要注意的一点是，我们使用 `getElementsByTagName` 获取 XML 元素的值，因此需要保证 XML 文件中的元素名称与代码中的元素名称一致。