Brian Hulette created BEAM-8330: ----------------------------------- Summary: PubSubIO.readAvros should produce a schema'd PCollection if clazz has a schema Key: BEAM-8330 URL: https://issues.apache.org/jira/browse/BEAM-8330 Project: Beam Issue Type: Improvement Components: io-java-gcp Affects Versions: 2.16.0 Reporter: Brian Hulette Assignee: Brian Hulette Fix For: 2.17.0
Currently {{PubsubIO.readAvros(clazz)}} *always* yields a PCollection with an AvroCoder. This should only be a fallback in the event that no coder can be inferred. That way if we can infer a schema for `clazz` we will produce a PCollection with a schema. -- This message was sent by Atlassian Jira (v8.3.4#803005)