cd $SPARK_HOME/sbinstart-thriftserver.sh &

package com.luogankun.spark.sqlimport java.sql.DriverManagerimport java.sql.Connectionimport java.sql.PreparedStatement/** * JDBC代码访问Thrift JDBC Server * @author luogankun */object JdbcThriftServer {  def main(args: Array[String]) {    Class.forName("org.apache.hive.jdbc.HiveDriver")    val conn = DriverManager.getConnection("jdbc:hive2://hadoop000:10000/default", "hadoop", "")    val pstat = conn.prepareStatement("SELECT track_time, url, session_id, referer, ip, end_user_id, city_id FROM page_views WHERE city_id = -1000 limit 10")    val rs = pstat.executeQuery()    while (rs.next()) {      println("track_time: " + rs.getString("track_time")        + ", url: " + rs.getString("url")        + ", session_id: " + rs.getString("session_id")        + ", referer: " + rs.getString("referer")        + ", ip: " + rs.getString("ip")        + ", end_user_id: " + rs.getString("end_user_id")        + ", city_id: " + rs.getString("city_id"))    }    rs.close()    pstat.close()    conn.close()  }}