Hi Kevin, I'm afraid AvroFileFormatFactory is not intended for the DataStream API. Have you tried adapting AvroParquetRecordFormat via StreamFormatAdapter?
Regards, Roman On Fri, Jan 7, 2022 at 7:23 PM Kevin Lam <kevin....@shopify.com> wrote: > > Hi all, > > We're looking into using the new FileSource API, we see that there is a > BulkFormat for Parquet, via ParquetColumnarRowFormat. Is there similar > BulkFormat available or in the works for Avro files? > > I imagined it may be a common use-case in the community so wanted to check > here before we invest time implementing our own. > > Thanks in advance!
