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)