2016-08-19 62 views
0

當我使用DataFlow作業執行BigQuery查詢時,我得到的TableRow對象因此不會返回那些屬於記錄類型列的列(展平)TableRow對象不返回dataFlow中的記錄類型列

Java代碼:

p.apply(BigQueryIO.Read.fromQuery(getQuery())) 

查詢:

SELECT BASM。 BAS, FROM (選擇user_ids.rmId AID,ID,user_ids.regis,從SEGMENT_ID(FLATTEN([data.base_audience_segment_map20160817],user_ids.rmId)))BASM 加入
(選擇類別,sub_category,類型,名稱,SEGMENT_ID, last_compute_day,來自[data.base_audience_segments]的描述)BAS on BASM.segment_id = BAS。 segment_id by BASM.AID,BASM.id limit 100

如果您在上述查詢中看到user_ids.rmId是可重複記錄類型列。

由於提前

回答

0

我覺得默認的行爲是,如果您的查詢返回空值比列列下的TableRow對象將不可見

0

您可能需要使用BigQueryIOwithout result flattening

p.apply(BigQueryIO.Read 
    .fromQuery(getQuery()) 
    .withoutResultFlattening())