Spark学习：spark读取HBase数据报异常java.io.NotSerializableException
1.准备工作，安装好HABSE之后，执行Hbase shell
create ‘表名称’, ‘列名称1’,’列名称2’,’列名称N’
create ‘表名称’,’列族名称’
在hbase中列是可以动态添加的，只需要有个列族就可以了
create 'test_lcc_person','lcc_liezu'
然后添加一些数据key相同的是一条数据，一共有6条数据
put ‘表名称’, ‘rowkey（相当于关系数据的ID,必须唯一）’, ‘列族名称：列名称:’, ‘值’
put 'test_lcc_person','1','lcc_liezu:name:','梁川川1'
put 'test_lcc_person','1','lcc_liezu:sex:','男'
put 'test_lcc_person','1','lcc_liezu:age:','12'put 'test_lcc_person','2','lcc_liezu:name:','梁川川2'
put 'test_lcc_person','2','lcc_liezu:sex:&#Spark学习：spark读取HBase数据报异常java.io.NotSerializableException相关推荐
- 异常java.io.NotSerializableException
这是spark保护函数的异常:传递局部可序列化变量或者顶级对象中的函数始终是安全的. 例如 val fun = new searchFun // println(fun.isMath("ru ...
- scala学习-scala读取Hbase表中数据并且做join连接查询
1.业务需求:sparkSQL on hbase ,sparkSQL直接读取Hbase中的两个表,进行连接查询. 2.图示 绿色的线 上图中绿色的线是做过测试的,直接在hive中建表,然后load数据 ...
- Spark连接redis问题 Caused by: java.io.NotSerializableException
**spark连接Redis的时候报错: ** Caused by: java.io.NotSerializableException: io.jimdb.JimdbNewCluster$$Enhan ...
- java socket 异常处理_socket编程报异常java.io.EOFException
一个客户端连接服务器的小程序,服务器端可以正常读取客户端发来的数据 但是当客户端关闭时,服务端也关闭了,并且抛出如下的异常: java.io.EOFException at java.io.DataI ...
- java后台调用SOE时，报异常java.io.IOException: Attempted read from closed stream
java后台调用SOE时,报异常java.io.IOException: Attempted read from closed stream 代码诸如此类 public void test(HttpS ...
- socket编程报异常java.io.EOFException
socket编程报异常java.io.EOFException 参考文章: (1)socket编程报异常java.io.EOFException (2)https://www.cnblogs.com/ ...
- java.io.NotSerializableException:异常
java.io.NotSerializableException:异常 参考文章: (1)java.io.NotSerializableException:异常 (2)https://www.cnbl ...
- hadoop异常: java.io.EOFException: Unexpected end of input stream
hadoop异常: java.io.EOFException: Unexpected end of input stream 参考文章: (1)hadoop异常: java.io.EOFExcepti ...
- 报错异常：java.io.NotSerializableException: daqi.base_io.Student
异常发生: 在通过使用ObjectOutputStream和ObjectInputStream测试对象的序列化时出现一个小异常,异常片段如下: java.io.NotSerializableExcep ...
最新文章
- 基于Springboot实现企业人事管理系统
- 动态规划1--最长公共子序列
- Python+Appium+POM实现APP端自动化测试
- caffe使用过程中遇到的问题和解决办法
- 打印三角形、已三角形方式 输出数组中的内容
- oracle as sydba,Oracle的操作系统认证（/ as sydba 登录方式）
- JAVA标准输出错误输出,从tsls输出中提取标准错误
- opencv 性能测试
- csstd超出部分用...替换
- Xcode9引第三方报错 linker command failed with exit code 1 (use -v to see invocation)
- HTML5框架 iframe用法 实现嵌套 好玩用法
- 对话DeepMind创始人：建立通用人工智能
- 计算机点击桌面无反应,点击显示桌面没反应? 显示桌面没反应解决方法
- 【180609】剑侠情缘_整套源码+地图编辑器(单机学习例子)
- 湖北经济学院法商学院计算机分数线,湖北经济学院法商学院2018年各省及各专业录取分数线及最低录投档线【理科 文科】...
- python提示takes no arguments_Python创建实例时提示错误takes no arguments，找不到什么原因？...
- Eclipse 工具上Springboot项目的简单 增删改查 的搭建
- 使用 Docker 来快速上手中文 Stable Diffusion 模型：太乙
- 记一次Max模型导入到GIS平台歪了，尺寸不对过程分析
- 淘宝婴儿产品销售的数据分析