读取 HBase
2018-08-31 本文已影响14人
焉知非鱼
// val df = sqlContext.read.format("jdbc")
// .option("driver", "org.apache.phoenix.jdbc.PhoenixDriver")
// .option("url", "jdbc:phoenix:10.1.83.25,10.1.83.26,10.1.83.27:2181:/hbase")
// .option("dbtable", "MILEAGE_ANXIETY")
// .load()
//
// val df = sqlContext.read.format("org.apache.phoenix.spark")
// .option("zkUrl", "10.0.201.123:2181")
// .option("table", "SYSTEM.CATALOG")
// .load()
