Я пытаюсь читать файлы avro с помощью Apache Beam и использовать Beam SQL для преобразования данных
Я пытаюсь применить SQLTransform к PCollection<Object>. Здесь преобразование CustomSource...
Я провожу некоторые эксперименты с Beam SQL.Я получаю PCollection<Row> из преобразования...