beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jean-Baptiste Onofré (JIRA) <>
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
             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:

pipeline.apply("Receive XML from JMS","MyQueue"))
            .apply("Convert as POJO",
            .apply("Convert POJO to something else", ....)
            .apply("Store somewhere", ...))

This message was sent by Atlassian JIRA

View raw message