Получение оригинального объекта неудачной вставки в GBQ в Google Dataflow

Question

Я использую Apache Beam для записи некоторых объектов в Google Big Query. Я использую код как

pipeline.apply(...)
        .apply(BigQueryIO.<MyObject>write().withFormatFunction(...))

Я обнаружил, что могу использовать метод .getFailedInsertsWithErr(), чтобы получить то, что TableRow не было вставлено.

Я хотел бы получить оригинальные MyObject объекты, которые вызывают неудачные вставки, чтобы обеспечить другой способ его обработки. Возможно ли достичь этого?

Answer 1

Это невозможно из коробки в данный момент. После применения BigQueryIO функции форматирования в строке не остается ссылки на исходный объект.