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?