From d7c8ce82ed4a26f11eb3e7cdd85f0aef4865bd37 Mon Sep 17 00:00:00 2001 From: Brandon Kvarda Date: Sat, 30 Jan 2016 16:11:58 -0800 Subject: [PATCH 1/2] Added ldap parameters to rimpala.connect() --- src/R/RImpala.R | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/R/RImpala.R b/src/R/RImpala.R index 66ddabc..117021e 100755 --- a/src/R/RImpala.R +++ b/src/R/RImpala.R @@ -71,15 +71,20 @@ rimpala.query <-function (Q="show tables",isDDL="false",fetchSize="10000") { } } -rimpala.connect <- function(IP="localhost",port="21050",principal="noSasl"){ +rimpala.connect <- function(IP="localhost",port="21050",principal="noSasl",user="none",password="none"){ impalaObj = .jnew("com.musigma.ird.bigdata.RImpala") #building the connection string #concat auth= or principal= depending on the user input to argument principal - if(principal=="noSasl") + if(principal=="noSasl" & user=="none") { principal = paste("auth=",principal,sep=""); - } else { + } + else if(principal=="noSasl" & user!="none") + { + principal = paste("user=",user,";","password=",password,sep="") + } + else { principal = paste("principal=",principal,sep=""); } From 6089684b31890d7131f90a367fd65a24cd3cf1b8 Mon Sep 17 00:00:00 2001 From: Brandon Kvarda Date: Sat, 30 Jan 2016 16:42:56 -0800 Subject: [PATCH 2/2] added db param to rimpala.connect --- src/R/RImpala.R | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/R/RImpala.R b/src/R/RImpala.R index 117021e..6762d8c 100755 --- a/src/R/RImpala.R +++ b/src/R/RImpala.R @@ -71,7 +71,7 @@ rimpala.query <-function (Q="show tables",isDDL="false",fetchSize="10000") { } } -rimpala.connect <- function(IP="localhost",port="21050",principal="noSasl",user="none",password="none"){ +rimpala.connect <- function(IP="localhost",port="21050",principal="noSasl",user="none",password="none",db="default"){ impalaObj = .jnew("com.musigma.ird.bigdata.RImpala") #building the connection string @@ -82,7 +82,7 @@ rimpala.connect <- function(IP="localhost",port="21050",principal="noSasl",user= } else if(principal=="noSasl" & user!="none") { - principal = paste("user=",user,";","password=",password,sep="") + principal = paste(db,";","user=",user,";","password=",password,sep="") } else { principal = paste("principal=",principal,sep="");