启动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()
}
}