Add multiple config support and use cos scheme

Author: bassel-zeidan

r/sparkr/R/osconfig.R

@@ -136,7 +136,7 @@ bluemix <- setRefClass("bluemix",
 CloudObjectStorage <- setRefClass("CloudObjectStorage",
   fields=list(configName="character"),
   methods=list(
-      initialize = function(..., sparkContext, credentials, configurationName){
+      initialize = function(..., sparkContext, credentials, configurationName="") {
 
 
           if (is.null(credentials["endpoint"][[1]])) {
@@ -151,20 +151,27 @@ CloudObjectStorage <- setRefClass("CloudObjectStorage",
               stop("Attribute secretKey in credentials is missing!")
           }
 
+          # bind config name
           .self$configName = configurationName
-          prefix = "fs.s3d.service"
+
+          # set prefix for hadoop config
+          prefix = paste("fs.cos", getConfigName(), sep='.')
           hConf = SparkR:::callJMethod(sparkContext, "hadoopConfiguration")
           SparkR:::callJMethod(hConf, "set", paste(prefix, "endpoint", sep='.'), credentials['endpoint'][[1]])
           SparkR:::callJMethod(hConf, "set", paste(prefix, "access.key", sep='.'), credentials['accessKey'][[1]])
           SparkR:::callJMethod(hConf, "set", paste(prefix, "secret.key", sep='.'), credentials['secretKey'][[1]])
       },
 
       getConfigName = function() {
-        return (.self$configName)
+        if (.self$configName != "") {
+          return (.self$configName)
+        }
+        return ("service")
       },
 
-      url = function(bucketName, objectName){
-          return(paste("s3d://", bucketName, ".service/", objectName, sep = ""))
+      url = function(bucketName, objectName) {
+        serviceName = getConfigName()
+        return (paste("cos://", bucketName, ".", serviceName, "/", objectName, sep = ""))
       }
   )
 )