Tôi cần biết cách phân tích các tệp XML trong Spark. Tôi đang nhận dữ liệu phát trực tuyến từ kafka và sau đó cần phân tích dữ liệu phát trực tuyến đó.
Đây là mã Spark của tôi để nhận dữ liệu:
directKafkaStream.foreachRDD(rdd ->{
rdd.foreach(s ->{
System.out.println("&&&&&&&&&&&&&&&&&" +s._2 );
});
và kết quả:
john
<điểm>90
điểm>
Làm cách nào để chuyển các phần tử XML này?
Cảm ơn tất cả các bạn .. vấn đề đã được giải quyết. Đây là giải pháp.
Chuỗi xml = "xyz";
Trình phân tích cú pháp DOMParser = DOMParser mới();
thử {
Parser.parse(InputSource mới(java.io.StringReader(xml)) mới);
Tài liệu doc = parser.getDocument();
Thông báo chuỗi = doc.getDocumentElement().getTextContent();
System.out.println(tin nhắn);
} catch (Exception e) {
// xử lý ngoại lệ SAX
}
Tôi là một lập trình viên xuất sắc, rất giỏi!