[jira] [Created] (BEAM-2228) XmlIO could work with a PCollection

["Jean-Baptiste Onofré (JIRA)" <ji...@apache.org>]

Jean-Baptiste Onofré created BEAM-2228:
------------------------------------------

             Summary: XmlIO could work with a PCollection
                 Key: BEAM-2228
                 URL: https://issues.apache.org/jira/browse/BEAM-2228
             Project: Beam
          Issue Type: New Feature
          Components: sdk-java-extensions
            Reporter: Jean-Baptiste Onofré
            Assignee: Jean-Baptiste Onofré


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:

{code}
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", ...))
{code}



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)