Phoenix映射HBase时间戳的一种实现
Phoenix映射HBase时间戳的一种实现
官方实现
Apache Phoenix从4.6版本开始,提供了ROW_TIMESTAMP标签,来映射HBase的原生时间戳。但使用起来有以下限制:
- 只有主键中的TIME, DATE, TIMESTAMP, BIGINT, UNSIGNED_LONG类型的字段才能设置成ROW_TIMESTAMP
- 只能有一个主键列能被设置成ROW_TIMESTAMP
- ROW_TIMESTAMP标志的字段不能为null值
- 只有在建表的时候,某一列才能被设置成ROW_TIMESTAMP
- ROW_TIMESTAMP标志的列不能为负数
除了上面使用上的限制,还有应用场景的限制。根据上面的描述,ROW_TIMESTAMP字段有以下几种形式。
- 业务主键在前
- ROW_TIMESTAMP字段在前
- 只有ROW_TIMESTAMP字段
我们来看下各

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
【云周刊】第221期:2019高考加油!盘点今年全国新增AI院校
欢迎订阅云周刊 本期头条 2019高考加油!盘点今年全国新增AI院校 2019年6月7日就是高考日。同学们加油!在2019年,若申报成功,仅“智能科学与技术”专业和“人工智能”专业的数量便将达到193个。2019全国新增AI院校大盘点。点击查看 蚂蚁金服终端实验室演进之路使用 Kafka + Spark Streaming + Cassandra 构建数据实时处理引擎漫谈分布式计算框架蚂蚁金服首席架构师何昌华:开源 SQLFlow 是牛刀初试,实时大数据系统才是未来基石【精彩活动预告】第十二届 BigData NoSQL Meetup (北京站)大咖云集,与你畅聊BigData NoSQL 技术干货 CICD联动阿里云容器服务Kubernetes实践之Bamboo篇 本文档以构建一个 Java 软件项目并部署到 阿里云容器服务的Kubernet
- 下一篇
Flink 闭包清除源码分析
0x1 摘要 本文主要讲解Flink里为什么需要做闭包清除?Flink是怎么实现闭包清除的? 0x2 Flink 为什么要做闭包清除 大家都知道Flink中算子都是通过序列化分发到各节点上,所以要确保算子对象是可以被序列化的,很多时候大家比较喜欢直接用匿名内部类实现算子,而匿名内部类就会带来闭包问题,当匿名内部类引用的外部对象没有实现序列化接口时,就会导致内部类无法被序列化,因此Flink框架底层必须做好清除工作。 0x3 Flink 闭包清除实现 先来看一个Map算子代码: final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); final DataStreamSource<String> source = env.addSource(new SourceFunction<String>() { @Override public void run(SourceContext<String> ctx) throws Exc...
相关文章
文章评论
共有0条评论来说两句吧...