1、能说下实时处理这块搭建的系统的架构吗？
2、SparkStreaming从kafka消费数据，怎么保证不会重复呢？偏移量也不是实时去提交，假如说在消费的过程中，出现重启，这种情况下怎么确保不会有部分数据重复处理？
SparkStreaming有这个机制吗？
3、sparkstreaming的工作过程。
4、采用redis对当日日活设备进行过滤统计，这个怎么理解呢？这样能实时动态的展示日活量吗？怎么统计的日活量？
5、大屏实时显示日活数，怎么做的？这里又用到redis又用到hbase，主要目的是什么呢？
为什么选择hbase呢，市面上也有一些关系型数据库是可以支撑的。
6、phenix的索引怎么做的呢？为什么会提高查询速率呢？
7、根据rowkey去hbase查数据的过程。
近期热帖
近期精华帖
-
扫描二维码，关注牛客
- 意见反馈
-
下载牛客APP，随时随地刷题
- 牛客竞赛，专业的竞技算法训练平台
-
扫描二维码，进入QQ群
扫码关注“比赛自动姬”
- 公司地址：北京市朝阳区北苑路北美国际商务中心K1座一层-北京牛客科技有限公司
- 联系方式：010-60728802 投诉举报电话：010-57596212（朝阳人力社保局）
- 牛客科技© All rights reserved admin@nowcoder.com
- 京ICP备14055008号-4 增值电信业务经营许可证 营业执照 人力资源服务许可证
-
京公网安备 11010502036488号
全部评论
(1) 回帖