Сводка шагов потока данных - BigQueryIO.writeTableRows () - PullRequest
Новая
       9

Сводка шагов потока данных - BigQueryIO.writeTableRows ()

0 голосов
/ 04 сентября 2018

При выполнении задания потока данных для выполнения записи BigQuery с помощью BigQueryIO.writeTableRows () я вижу, что в сводке шага потока данных не указано количество элементов, вставленных в BigQuery для шага записи BigQuery. Но строки были успешно вставлены в BigQuery.

Это ожидается или проблема? 

pipeline.apply(
                BigQueryIO.writeTableRows()
                .withoutValidation()            .withCustomGcsTempLocation(options.getBigQueryLoadingTemporaryDirectory())
                .withSchema(FormatUserScoreSumsSampleFn.getSchema())
                .to("sandboxproject:dataset1.testtable")
                .withCreateDisposition(CreateDisposition.CREATE_IF_NEEDED)
                .withWriteDisposition(WriteDisposition.WRITE_APPEND)
                )
...