Does AvroIO.readGenericRecords() work ? https://github.com/apache/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/io/AvroIO.java#L333
Thanks, Cham On Thu, Jun 13, 2019 at 1:46 PM Neville Li <[email protected]> wrote: > Hi, > > Is it just me or is there no way for AvroIO to read SpecificRecords with > a custom reader schema? > > AvroIO.read(Class<T> recordClass) will use the schema of T and there's no > way to override it. > > Cheers, > Neville >
