library(rJava)
library(RJDBC)
library(DBI)
Sys.setenv("HADOOP_CMD"="/usr/hdp/2.3.2.0-2950/hadoop/bin/hadoop")
Sys.setenv("HADOOP_HOME"="/usr/hdp/2.3.2.0-2950/hadoop")
Sys.setenv("HADOOP_PREFIX"="/usr/hdp/2.3.2.0-2950/hadoop")
Sys.setenv("HADOOP_CONF_DIR"="/usr/hdp/2.3.2.0-2950/hadoop/conf")
Sys.setenv("HIVE_HOME"="/usr/hdp/current/hive-client/lib")
options( java.parameters = "-Xmx8g" ) # 데이터 용량에 따라 변경
drv <- JDBC("org.apache.hive.jdbc.HiveDriver", "/usr/hdp/2.4.2.0-258/hive/lib/hive-jdbc.jar")
conn <- dbConnect(drv, "jdbc:hive2://192.168.100.10:10000/default", "admin", "admin") # hive사용자
# 쿼리 예제임
db_query <- dbGetQuery(conn, "show tables")
db_query # 테이블명 출력
덧글