[ https://issues.apache.org/jira/browse/BEAM-8330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Brian Hulette updated BEAM-8330: -------------------------------- Priority: P3 (was: P2) > 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 > Reporter: Brian Hulette > Priority: P3 > Labels: stale-P2 > > 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)