7 // SetHdfsParametersByObjectMap set the value of the hdfs config parameters
8 // and return HdfsConfig object
9 func SetHdfsParametersByObjectMap(m map[string]interface{}) HdfsConfig{
12 hc.hdfsURL = m["hdfs_url"].(string)
17 // SetHdfsParametersByEnvVariables sets the hdfs parameters
18 func SetHdfsParametersByEnvVariables() HdfsConfig {
20 slogger := GetLoggerInstance()
21 hdfsConfigObject := HdfsConfig{
22 hdfsURL: os.Getenv("HDFS_URL"),
24 slogger.Infof("::hdfsURL:: %s", hdfsConfigObject.hdfsURL)
25 return hdfsConfigObject
29 // HdfsConfig contains hdfs related config items
30 type HdfsConfig struct {
34 // GetHdfsURL returns HdfsURL
35 func (h HdfsConfig) GetHdfsURL() string {