启动ThriftJDBCServer:

cd $SPARK_HOME/sbin
start-thriftserver.sh &

使用jdbc访问ThriftJDBCServer代码段：

package com.luogankun.spark.sql

import java.sql.DriverManager
import java.sql.Connection
import java.sql.PreparedStatement

/**
* JDBC代码访问Thrift JDBC Server
* @author luogankun
*/
object JdbcThriftServer {
def main(args: Array[String]) {
Class.forName("org.apache.hive.jdbc.HiveDriver")

}
rs.close()
pstat.close()
conn.close()
}
}