Hivecontext.sql 返回空结果火花

Question

我正在创建配置单元上下文并查询配置单元表，如下所示， spark上下文是使用yarn-cluster创建的

HiveContext hv = new HiveContext(sc)
hv.sql("use schema")
val df = hv.sql(query)

但是它返回一个空的数据框。

但是，如果我直接在 hive 环境中运行查询，它会返回有效值。可能是什么问题

Answer 1

通常，spark 中的数据帧可以被视为检索/计算数据的映射，直到需要数据时才会物化。 为了获取数据，您可以使用 df.collect()