beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jean-Baptiste Onofré (JIRA) <j...@apache.org>
Subject [jira] [Created] (BEAM-2228) XmlIO could work with a PCollection
Date Tue, 09 May 2017 12:27:04 GMT
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)

Mime
View raw message