Я пытаюсь читать файлы avro с помощью Apache Beam и использовать Beam SQL для преобразования данных

Я пытаюсь применить SQLTransform к PCollection<Object>. Здесь преобразование CustomSource...

Я провожу некоторые эксперименты с Beam SQL.Я получаю PCollection<Row> из преобразования...