BigQueryの繰り返しレコードは、アレイの外側に加え

Question

エラー：

Exception in thread "main" java.lang.RuntimeException 
{"errors":[{"debugInfo":"generic::failed_precondition: Repeated record added outside of an array.","reason":"invalid"}],"index":0} 

言語：スカラ

のGradle BigQueryの依存：

：

compile "com.google.apis:google-api-services-bigquery:v2-rev326-1.22.0" 

テーブルスキーマを生成するためのコード

import scala.collection.JavaConversions._ 
val orderTableSchema = new TableSchema() 
orderTableSchema.setFields(Seq(
    new TableFieldSchema().setName("revisionId").setType("STRING").setMode("REQUIRED"), 
    new TableFieldSchema().setName("executions").setType("RECORD").setMode("REPEATED").setFields(Seq(
    new TableFieldSchema().setName("ts").setType("INTEGER"), 
    new TableFieldSchema().setName("price").setType("FLOAT"), 
    new TableFieldSchema().setName("qty").setType("INTEGER") 
)) 
)) 

BigQueryのウェブUIに示すよう

テーブルが実行カラムの正しいスキーマで正常に作成された：

import scala.collection.JavaConversions._ 
val row = new TableRow() 
    .set("revisionId", "revision1") 
    .set("executions", Seq(
    new TableRow().set("ts", 1L).set("price", 100.01).set("qty", 1000) 
)) 
val content = new TableDataInsertAllRequest().setRows(Seq(
    new TableDataInsertAllRequest.Rows().setJson(row) 
)) 
val insertAll = bigQuery.tabledata().insertAll(projectId, datasetId, "order", content) 
val insertResponse = insertAll.execute() 

if (insertResponse.getInsertErrors != null) { 
    insertResponse.getInsertErrors.foreach(println) 
    // this prints: 
    // {"errors":[{"debugInfo":"generic::failed_precondition: Repeated record added outside of an array.","reason":"invalid"}],"index":0} 

    // throw to just terminate early for demo 
    throw new RuntimeException() 
} 

Answer 1

は問題が見つかりました：

revisionId   STRING REQUIRED  
executions   RECORD REPEATED 
executions   RECORD REPEATED 
executions.ts  INTEGER NULLABLE 
executions.price FLOAT NULLABLE 
executions.qty  INTEGER NULLABLE 

コードは失敗し、データを挿入します。

これは、scala-to-javaコレクションの変換が混乱するものです。私は、JavaConversions.seqAsJavaListを使って明示的に変換を追加しなければならず、魔法のように動作するようになった。

val row = new TableRow() 
    .set("revisionId", s"revisionId$v") 
    .set("executions", JavaConversions.seqAsJavaList(Seq(
    new TableRow().set("ts", 1L).set("price", 100.01).set("qty", 1000), 
    new TableRow().set("ts", 2L).set("price", 100.02).set("qty", 2000), 
    new TableRow().set("ts", 3L).set("price", 100.03).set("qty", 3000) 
)))