[BEAM-2228] XmlIO could work with a PCollection

• Type: New Feature
• Status: Open
• Priority: P3
• Resolution: Unresolved
• Component/s: io-ideas
• Assignee: Unassigned
• Reporter: Jean-Baptiste Onofré
• Created: 09/May/17 12:26
• Updated: 03/Jun/22 17:23

Description

Currently, XmlIO can "only" read from a XML file (using from()).

I could be interesting to have XmlIO "generic" PTransform to convert each element in an incoming PCollection as POJO.

For instance, doing something like:

pipeline.apply("Receive XML from JMS", JmsIO.read().withConnectionFactory(xx).withQueue("MyQueue"))
            .apply("Convert as POJO", XmlIO.read()...)
            .apply("Convert POJO to something else", ....)
            .apply("Store somewhere", ...))

Issue Links

• is related to: BEAM-1581 JSON source and sink