import org.apache.spark.SparkConf import org.apache.spark.SparkContext import org.apache.spark.sql.SQLContext import org.apache.spark.sql._ import org.apache.phoenix.spark._ object DataFrame { def main(args: Array[String]) { val conf = new SparkConf().setMaster("local").setAppName("DataFrame") val sc = new SparkContext(conf) val sqlContext = new SQLContext(sc) import sqlContext.implicits._ import sqlContext._ val df1 = sqlContext.load( "org.apache.phoenix.spark", Map("table" -> "TEST1", "zkUrl" -> "hostname:/hbase-unsecure") ) df1.show() } }