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