Невозможно использовать useBeamSchema для автоматического преобразования Pcollection в схему строк таблицы - PullRequest
Новая
       5

Невозможно использовать useBeamSchema для автоматического преобразования Pcollection в схему строк таблицы

0 голосов
/ 31 марта 2020

// Follwing код для чтения файла из корзины GCS, преобразования и записи в Bigquery 

    PCollection<Quote> quotes = ...//get tranfrometed data 

     quotes.apply(BigQueryIO
         .<Quote>write()
         .to("my-project:my_dataset.my_table")
         .useBeamSchema()
         .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_`enter code here`TRUNCATE));

     //get error 
    //Exception in thread "main" java.lang.IllegalArgumentException: Unable to infer a coder and no Coder was //specified. Please set a coder by invoking Create.withCoder() explicitly  or a schema by invoking //Create.withSchema().

1 Ответ

1 голос
/ 31 марта 2020

Я думаю, вам нужно установить схему в вашем PCollection. Пожалуйста, см. пример ниже.

...