thriftserver&beeline的使用
2017-12-22 21:36
429 查看
启动thriftserver::默认端口是10000 ,可以修改
2.启动beeline
修改thriftserver启动占用的默认端口号:
thriftserver和普通的spark-shell/spark-sql有什么区别?
1)spark-shell、spark-sql都是一个spark application;
2)thriftserver, 不管你启动多少个客户端(beeline/code),永远都是一个spark application
解决了一个数据共享的问题,多个客户端可以共享数据;
通过JDBC的方式访问(程序实现)
./sbin/start-thriftserver.sh --master local[2]
2.启动beeline
./bin/beeline -u jdbc:hive2://localhost:10000 -n hadoop
0: jdbc:hive2://localhost:10000> show tables; +-----------+------------+--------------+--+ | database | tableName | isTemporary | +-----------+------------+--------------+--+ | default | dept | false | | default | emp | false | +-----------+------------+--------------+--+ 2 rows selected (0.456 seconds)
0: jdbc:hive2://localhost:10000> select * from emp; +--------+---------+------------+-------+-------------+----------+---------+---------+--+ | empno | ename | job | mgr | hiredate | sal | comm | deptno | +--------+---------+------------+-------+-------------+----------+---------+---------+--+ | 7369 | SMITH | CLERK | 7902 | 1980-12-17 | 800.0 | NULL | 20 | | 7499 | ALLEN | SALESMAN | 7698 | 1981-2-20 | 1600.0 | 300.0 | 30 | | 7521 | WARD | SALESMAN | 7698 | 1981-2-22 | 1250.0 | 500.0 | 30 | | 7566 | JONES | MANAGER | 7839 | 1981-4-2 | 2975.0 | NULL | 20 | | 7654 | MARTIN | SALESMAN | 7698 | 1981-9-28 | 1250.0 | 1400.0 | 30 | | 7698 | BLAKE | MANAGER | 7839 | 1981-5-1 | 2850.0 | NULL | 30 | | 7782 | CLARK | MANAGER | 7839 | 1981-6-9 | 2450.0 | NULL | 10 | | 7788 | SCOTT | ANALYST | 7566 | 1987-4-19 | 3000.0 | NULL | 20 | | 7839 | KING | PRESIDENT | NULL | 1981-11-17 | 5000.0 | NULL | 10 | | 7844 | TURNER | SALESMAN | 7698 | 1981-9-8 | 1500.0 | 0.0 | 30 | | 7876 | ADAMS | CLERK | 7788 | 1987-5-23 | 1100.0 | NULL | 20 | | 7900 | JAMES | CLERK | 7698 | 1981-12-3 | 950.0 | NULL | 30 | | 7902 | FORD | ANALYST | 7566 | 1981-12-3 | 3000.0 | NULL | 20 | | 7934 | MILLER | CLERK | 7782 | 1982-1-23 | 1300.0 | NULL | 10 | | 8888 | HIVE | PROGRAM | 7839 | 1988-1-23 | 10300.0 | NULL | NULL | +--------+---------+------------+-------+-------------+----------+---------+---------+--+ 15 rows selected (1.349 seconds)
0: jdbc:hive2://localhost:10000> select * from emp e join dept d on e.deptno = d.deptno; +--------+---------+------------+-------+-------------+---------+---------+---------+---------+-------------+-----------+--+ | empno | ename | job | mgr | hiredate | sal | comm | deptno | deptno | dname | location | +--------+---------+------------+-------+-------------+---------+---------+---------+---------+-------------+-----------+--+ | 7369 | SMITH | CLERK | 7902 | 1980-12-17 | 800.0 | NULL | 20 | 20 | RESEARCH | DALLAS | | 7499 | ALLEN | SALESMAN | 7698 | 1981-2-20 | 1600.0 | 300.0 | 3 4000 0 | 30 | SALES | CHICAGO | | 7521 | WARD | SALESMAN | 7698 | 1981-2-22 | 1250.0 | 500.0 | 30 | 30 | SALES | CHICAGO | | 7566 | JONES | MANAGER | 7839 | 1981-4-2 | 2975.0 | NULL | 20 | 20 | RESEARCH | DALLAS | | 7654 | MARTIN | SALESMAN | 7698 | 1981-9-28 | 1250.0 | 1400.0 | 30 | 30 | SALES | CHICAGO | | 7698 | BLAKE | MANAGER | 7839 | 1981-5-1 | 2850.0 | NULL | 30 | 30 | SALES | CHICAGO | | 7782 | CLARK | MANAGER | 7839 | 1981-6-9 | 2450.0 | NULL | 10 | 10 | ACCOUNTING | NEW YORK | | 7788 | SCOTT | ANALYST | 7566 | 1987-4-19 | 3000.0 | NULL | 20 | 20 | RESEARCH | DALLAS | | 7839 | KING | PRESIDENT | NULL | 1981-11-17 | 5000.0 | NULL | 10 | 10 | ACCOUNTING | NEW YORK | | 7844 | TURNER | SALESMAN | 7698 | 1981-9-8 | 1500.0 | 0.0 | 30 | 30 | SALES | CHICAGO | | 7876 | ADAMS | CLERK | 7788 | 1987-5-23 | 1100.0 | NULL | 20 | 20 | RESEARCH | DALLAS | | 7900 | JAMES | CLERK | 7698 | 1981-12-3 | 950.0 | NULL | 30 | 30 | SALES | CHICAGO | | 7902 | FORD | ANALYST | 7566 | 1981-12-3 | 3000.0 | NULL | 20 | 20 | RESEARCH | DALLAS | | 7934 | MILLER | CLERK | 7782 | 1982-1-23 | 1300.0 | NULL | 10 | 10 | ACCOUNTING | NEW YORK | +--------+---------+------------+-------+-------------+---------+---------+---------+---------+-------------+-----------+--+ 14 rows selected (0.569 seconds)
修改thriftserver启动占用的默认端口号:
./start-thriftserver.sh \ --master local[2] \ --jars ~/software/mysql-connector-java-5.1.27-bin.jar \ --hiveconf hive.server2.thrift.port=14000 beeline -u jdbc:hive2://localhost:14000 -n hadoop
thriftserver和普通的spark-shell/spark-sql有什么区别?
1)spark-shell、spark-sql都是一个spark application;
2)thriftserver, 不管你启动多少个客户端(beeline/code),永远都是一个spark application
解决了一个数据共享的问题,多个客户端可以共享数据;
通过JDBC的方式访问(程序实现)
import java.sql.DriverManager /** * Created by **** 2017/12/22 22:03 * 通过JDBC的方式访问 */ object SparkSQLThriftServerApp { def main(args: Array[String]): Unit = { Class.forName("org.apache.hive.jdbc.HiveDriver") //注意:要先启动thriftserver ./sbin/start-thriftserver.sh --master local[2] val conn = DriverManager.getConnection("jdbc:hive2://172.17.66.51:10000", "hadoop", "") val pstmt = conn.prepareStatement("select empno,ename,sal from emp") val rs = pstmt.executeQuery() while (rs.next()) { println("empno:" + rs.getInt("empno") + ", ename:" + rs.getString("ename") + ", sal:" + rs.getDouble("sal")) } } }
相关文章推荐
- Spark thriftserver和beeline的简单使用
- SQL Server与使用防火墙(1) -- SQL Server & Firewall
- Request.ServerVariables["REMOTE_ADDR"]的使用方法
- Request.ServerVariables["LOGON_USER"] 如何使用
- MonitorServer代码阅读笔记(一):使用sigaction( SIGPIPE, &sa, 0)避免写一个已关闭的socket导致进程退出
- Thrift使用入门(2) - 用Thrift实现一个简单的Server/Client应用程序
- Nebula2探秘01-创建KernelServer&使用log
- ASP.NET中使用<script runat="server">
- <车载物联网项目,视频采集传输部分,第二天> 使用ffserver输出视频文件流,并且使用使用命令行终端播放视频文件
- 单入口框架使用$_SERVER['PHP_SELF']遇到的问题
- SQL Server 数据库使用备份还原造…
- 使用sqlserver"查找和替换"的正则表达式和通配符功能
- Thrift 各种server 使用模式
- 使用Putty登录Ubuntu后得到"Server refused our key"错误的一种解决方法
- 使用T-SQL实现数据导出/导入(SQLSERVER—>SQLSERVER)
- Hbase & Thrift , 使用C++访问Hbase
- <车载物联网项目,视频采集传输部分,第三天> 使用ffserver输出视频文件流,并且使用使用命令行终端播放视频文件
- Nebula2探秘01-创建KernelServer&使用log
- HIVE Thrift Server使用总结
- Request.ServerVariables("HTTP_REFERER")不能使用