Используя Apache Beam Python SDK, я настроил поток данных, который записывает данные в отдельные разделы в таблице разделов по датам в Big Query.Согласно этой документации каждая секционированная таблица дат имеет специальные NULL
и UNPARTITIONED
разделы.Согласно этим документам, я могу записать в раздел UNPARTITIONED
, просто установив дату в прошлом или будущем, но как я могу записать в раздел NULL
?
Я пытаюсь загрузить данные в раздел, основанный на значениях в данных, и иногда поле имеет значение null.Я лучше напишу в раздел NULL
, чем составлю дату для использования с нулями.
Для справки я пишу на сегодняшний день разделы, выполняя что-то вроде этого:
beam.io.Write(beam.io.BigQuerySink(table_id+'$20180925',
project=project_id, dataset=dataset_id, schema=schema))
Чем мне нужно заменить $20180925
на запись в NULL
?