采纳答案成功!
向帮助你的同学说点啥吧!感谢那些助人为乐的人
conf.set(TableInputFormat.SCAN, Base64.encodeBytes(ProtobufUtil.toScan(scan).toByteArray))
是否需要封装一个单例类呢?
说的对的,建议封装,然后用池
scala里 我不会封装啊,hbase连接池要怎么写啊,老师能否调用java的hbase封装类?
可以的,不会的东西需要自己去学会,充实自我
登录后可查看更多问答,登录/注册
Flume+Kafka+Spark Streaming 构建通用实时流处理平台
1.8k 89
1.2k 14
2.4k 13
1.8k 12
2.5k 12
购课补贴联系客服咨询优惠详情
慕课网APP您的移动学习伙伴
扫描二维码关注慕课网微信公众号