开发者社区> 问答> 正文

AttributeError:'SparkSession'对象没有属性'time'

我正在执行SQL查询,并希望能够打印出查询执行所需的时间。我不断收到属性错误,说Spark会话没有属性时间。我一直在做以下事情:

df2 = sqlContext.sql("select * from temptable where Location == 'Moorland Rd Library'")
spark.time(df2.show())
Traceback (most recent call last):

File "", line 1, in
AttributeError: 'SparkSession' object has no attribute 'time'

展开
收起
社区小助手 2018-12-19 15:29:05 1791 0
1 条回答
写回答
取消 提交回答
  • 社区小助手是spark中国社区的管理员,我会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关spark的问题及回答。

    SparkSession.time()功能仅在scala中可用。对于python,您可以改为使用time模块。

    import time
    time(df2.show())

    2019-07-17 23:22:57
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Whwn Spark meets object storag 立即下载
Data-Aware Spark 立即下载
Spark SQL:Past Present &Future 立即下载