【发布时间】:2017-11-12 18:34:28
【问题描述】:
我有以下规则的情况:
- 用户一次只能在一个场所。如果用户 A 在场地 X 登记,然后在 地点 Y,他们不再在地点 X。
- 签到最多只能“持续”3 小时。如果用户 A 在场地 X 签到,然后签到 3小时内什么都没有,他们已经不在X场地了。
数据将使用 Kafka 和 spark-streaming 解析到 HBase。
我想使用 HBase,TTL 为 3 小时,版本控制为 1,满足上述条件。问题是我很困惑如何在 HBase 中组织数据以获得更快的查询响应,我应该使用带有场地名称或场地名称的单个列作为不同的列名吗?
哪个是更好的选择,为什么?
需要执行的查询是: 1. 用户 A 现在在哪里? 2. X 场馆现在有哪些用户?
【问题讨论】:
-
预计有多少用户和多少场地?什么是读写比?预计每秒有多少请求?
-
这是实时查询的新实现。目前一切都会减少,但希望每个公共场所都成为一个场所。
标签: mongodb hadoop cassandra hbase