2017-03-16 78 views
2

我們有一個與Avro的劃分是這樣的:星火1.6負載特定的分區在數據幀保存分區字段

table 
--a=01 
--a=02 

我們希望從單個分區保持分區列裝載數據。 我發現this stackoverflow question和我申請建議片段:

DataFrame df = hiveContext.read().format(format). 
option("basePath", "path/to/table/"). 
load("path/to/table/a=01") 

,但是當我嘗試閱讀領域一個它說:

org.apache.spark.sql.AnalysisException: cannot resolve 'a' given input columns: [b, c, d] 

是否有可能在星火Java API的1.6?

回答

0

簡而言之,答案是......不,這是不可能的。