package main

import ( "encoding/json" "fmt" )

// Spark 环境配置 type SparkEnv struct { LocalShuffleEnabled string json:"spark.sql.adaptive.localShuffleReader.enabled" SkewJoinEnabled string json:"spark.sql.adaptive.skewJoin.enabled" AdaptiveEnabled string json:"spark.sql.adaptive.enabled" JoinReorderEnabled string json:"spark.sql.cbo.joinReorder.enabled" }

func main() { str := spark.sql.adaptive.localShuffleReader.enabled true spark.sql.adaptive.skewJoin.enabled true spark.sql.adaptive.enabled true spark.sql.cbo.joinReorder.enabled false

var sparkEnv SparkEnv

fmt.Println("Before conversion:")
fmt.Println(str)

err := json.Unmarshal([]byte(str), &sparkEnv)
if err != nil {
	fmt.Println("Error:", err)
	return
}

fmt.Println("\nAfter conversion:")
fmt.Printf("%+v", sparkEnv)

}

Go 语言将字符串转换为结构体 - Spark 配置解析

原文地址: https://www.cveoy.top/t/topic/pgrC 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录