调用sql()和使用spark api call()的区别

kx5bkwkv  于 2021-06-26  发布在  Hive
关注(0)|答案(1)|浏览(348)

我是spark/scala/hive的新手。我只是想知道打电话和打电话有什么不同

spark = new SparkSession(...).getHiveContext()
spark.sql("SELECR * FROM table")

spark = new SparkSession(...).getHiveContext() // not using
spark.read.table(table).select(from("*"))

??
特别是,是否存在性能差异。

iezvtpos

iezvtpos1#

这两个代码段具有相同的运行时性能。
第二个api更安全,如果你输入了一个错误,或者试图使用一些不受支持的操作,它会给你一个快速而清晰的编译错误。你写的很有趣 SELECR 而不是 SELECT ,这很好地说明了这一点:)

相关问题