Anton Kedin created BEAM-4197:
---------------------------------

             Summary: Add tests for PubsubIO.readXxx() -> Row
                 Key: BEAM-4197
                 URL: https://issues.apache.org/jira/browse/BEAM-4197
             Project: Beam
          Issue Type: Improvement
          Components: sdk-java-core
            Reporter: Anton Kedin


PubsubIO has methods like PubsubIO.readStrings(), PubsubIO.readAvros() and 
PubsubIO.readProtos(). We need to add tests to make sure it's easy to convert 
objects read from Pubsub to Rows, e.g. using JsonToRow transform, or 
InferredRowCoder.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to