5 "github.com/colinmarc/hdfs"
11 //var clientOnce sync.Once
12 //var hdfsClient *hdfs.Client
13 //var slogger *zap.SugaredLogger
16 //GetHdfsClientInstance returns a singleton hdfsClient instance
17 // func GetHdfsClientInstance(hdfsURL string) (*hdfs.Client){
18 // clientOnce.Do(func(){
19 // hdfsClient = createHdfsClient(hdfsURL)
24 //CreateHdfsClient creates a hdfs client and returns hdfs client
25 func CreateHdfsClient(hdfsURL string) (*hdfs.Client){
26 slogger := GetLoggerInstance()
27 hdfsClient, hdfsConnectError := hdfs.New(hdfsURL)
28 if hdfsConnectError !=nil {
29 slogger.Fatalf(":::Error in create hdfsClient::: %v", hdfsConnectError)
30 fmt.Printf("::Unable to initialize hdfsURL, check logs")