Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- library(rJava)
- library(DBI)
- library(RJDBC)
- options(java.parameters = paste0("-Xmx", java.size, "g"))
- print(paste("java.parameters :", getOption("java.parameters")))
- cp = c("/opt/lib/PR/hive-jdbc.jar", "/opt/lib/PR/hadoop-common.jar")
- .jinit(classpath = cp)
- drv <- JDBC("org.apache.hive.jdbc.HiveDriver", "/opt/lib/PR/hive-jdbc.jar",
- identifier.quote = "`")
- password = getPass::getPass(msg = "Hive password")
- conn <- DBI::dbConnect(drv, "jdbc:hive2://hadoop-training.s.com:10000/sni",
- user = Sys.info()["user"], password)
- conn
- dbWriteTable(conn, "exempletable", df, append = TRUE, overwrite = FALSE)
Add Comment
Please, Sign In to add comment