Apache Beam - получение некоторых полей в моих записях как пустых - PullRequest
0 голосов
/ 09 апреля 2020

Я выполняю операцию Beam SQL, которая дает мне PCollection<Row>, а затем я преобразую формат строки в обобщенную c запись, чтобы записать в файл, используя AvroUtils.toGenericRecord(row, avroschema).

Проблема в том, что некоторые поля в записях имеют вид null Есть ли какое-то решение для этого?

...