通过jdbc连接hive报java.sql.SQLException: Method not supported问题
jdbc连接hive
·
动态加载jar包,把jar包放在电脑任意位置。
File dir = new File("C:\\Users\\zhouy\\Desktop\\jdbc\\资料\\资料\\资料");
listAllFile(dir);
SparkSession session = SparkSession
.builder()
.appName("mysql_to_hive")
.master("local[*]")
// .enableHiveSupport() 不使用hive-spark整合依赖
.getOrCreate();
Properties properties3 = new Properties();
properties3.put("driver", "com.cloudera.hive.jdbc41.HS2Driver");
properties3.put("user", "hive");
properties3.put("password", "hive");
Dataset<Row> df_read3 = session.read().
jdbc("jdbc:hive2://172.17.3.183:10000/zyj_hive_study", "zyj_hive_study.student", properties3);
df_read3.show();
成功运行。
问题点:
更多推荐
所有评论(0)