我在这个博客中看到了下面的片段
val warehouseLocation = "file:${system:user.dir}/spark-warehouse"
val spark = SparkSession
.builder()
.appName("SparkSessionZipsExample")
.config("spark.sql.warehouse.dir", warehouseLocation)
.enableHiveSupport()
.getOrCreate()
如何user.dir在仓库位置值中替换系统属性。字符串不应该是s"file:${System.getProperty("user.dir")}/spark-warehouse"吗？
是的，file:${system:user.dir}/spark-warehouse是等于 s"file:${System.getProperty("user.dir")}/spark-warehouse"。
在Spark 中，它自己实现了替换，绑定了从env( System.getEnv), system( System.getProperty)前缀读取配置或自定义配置provider。
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句