元注解:@Retention 在hbase中用于获取确定高优先级的RPC操作

简介:

概念

        注解@Retention可以用来修饰注解,是注解的注解,称为元注解。
        Retention注解有一个属性value,是RetentionPolicy类型的,Enum RetentionPolicy是一个枚举类型,
        这个枚举决定了Retention注解应该如何去保持,也可理解为Rentention 搭配 RententionPolicy使用。

        RetentionPolicy有3个值:CLASS  RUNTIME   SOURCE
        用@Retention(RetentionPolicy.CLASS)修饰的注解,表示注解的信息被保留在class文件(字节码文件)中当程序编译时,但不会被虚拟机读取在运行的时候;
        用@Retention(RetentionPolicy.SOURCE )修饰的注解,表示注解的信息会被编译器抛弃,不会留在class文件中,注解的信息只会留在源文件中;
        用@Retention(RetentionPolicy.RUNTIME )修饰的注解,表示注解的信息被保留在class文件(字节码文件)中当程序编译时,会被虚拟机保留在运行时,
        所以他们可以用反射的方式读取。RetentionPolicy.RUNTIME 可以让你从JVM中读取Annotation注解的信息,以便在分析程序的时候使用.

在hbase中的使用

        参见类org.apache.hadoop.hbase.regionserver.AnnotationReadingPriorityFunction

        用于确定高优先级的RPC操作

        1:如果请求的方法使用了QosPriority of QOS_HIGH注释,则认为是高优先级

        2:如果请求是操作meta region,则认为是高优先级(代码层面针对此做了一些优化操作,避免过早的反序列化PB对象)

代码示例

import java.lang.annotation.Retention;
import java.lang.annotation.RetentionPolicy;
import java.lang.reflect.Method;
import java.net.UnknownHostException;
import java.util.HashMap;
import java.util.Map;

import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CloseRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.CompactRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetOnlineRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.GetRegionInfoResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.MergeRegionsResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.OpenRegionResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse;
import org.apache.hadoop.hbase.protobuf.generated.AdminProtos.SplitRegionResponse;

@SuppressWarnings("unchecked")
public class Test {
	public static void main(String[] args) throws UnknownHostException {
		Test test = new Test();
	}

	public Test() {
		Map<String, Integer> qosMap = new HashMap<String, Integer>();
		for (Method m : Test.class.getMethods()) {
			QosPriority p = m.getAnnotation(QosPriority.class);
			if (p != null) {
				String capitalizedMethodName = capitalize(m.getName());
				qosMap.put(capitalizedMethodName, p.priority());
				System.out.println(capitalizedMethodName + "," + p.priority());
			}
		}
	}

	@Retention(RetentionPolicy.RUNTIME)
	protected @interface QosPriority {
		int priority() default 0;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public GetRegionInfoResponse getRegionInfo() {
		System.out.println("getRegionInfo");
		return null;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public GetOnlineRegionResponse getOnlineRegion() {
		System.out.println("getOnlineRegion");
		return null;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public OpenRegionResponse openRegion() {
		System.out.println("openRegion");
		return null;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public CloseRegionResponse closeRegion() {
		System.out.println("closeRegion");
		return null;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public SplitRegionResponse splitRegion() {
		System.out.println("splitRegion");
		return null;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public MergeRegionsResponse mergeRegions() {
		System.out.println("mergeRegions");
		return null;
	}

	@QosPriority(priority = HConstants.HIGH_QOS)
	public CompactRegionResponse compactRegion() {
		System.out.println("compactRegion");
		return null;
	}

	@QosPriority(priority = HConstants.REPLICATION_QOS)
	public ReplicateWALEntryResponse replicateWALEntry() {
		System.out.println("replicateWALEntry");
		return null;
	}

	@QosPriority(priority = HConstants.REPLAY_QOS)
	public ReplicateWALEntryResponse replay() {
		System.out.println("replay");
		return null;
	}

	private String capitalize(final String s) {
		StringBuilder strBuilder = new StringBuilder(s);
		strBuilder.setCharAt(0, Character.toUpperCase(strBuilder.charAt(0)));
		return strBuilder.toString();
	}
}
相关实践学习
云数据库HBase版使用教程
&nbsp; 相关的阿里云产品:云数据库 HBase 版 面向大数据领域的一站式NoSQL服务,100%兼容开源HBase并深度扩展,支持海量数据下的实时存储、高并发吞吐、轻SQL分析、全文检索、时序时空查询等能力,是风控、推荐、广告、物联网、车联网、Feeds流、数据大屏等场景首选数据库,是为淘宝、支付宝、菜鸟等众多阿里核心业务提供关键支撑的数据库。 了解产品详情:&nbsp;https://cn.aliyun.com/product/hbase &nbsp; ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库&nbsp;ECS 实例和一台目标数据库&nbsp;RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&amp;RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
目录
相关文章
|
4月前
|
Java Shell 分布式数据库
【大数据技术Hadoop+Spark】HBase数据模型、Shell操作、Java API示例程序讲解(附源码 超详细)
【大数据技术Hadoop+Spark】HBase数据模型、Shell操作、Java API示例程序讲解(附源码 超详细)
84 0
|
7月前
|
Shell 分布式数据库 Apache
Hbase常用shell操作
Hbase常用shell操作
321 1
|
7月前
|
Java Shell 分布式数据库
HBase高级操作
HBase高级操作
202 0
|
4月前
|
分布式计算 Hadoop Shell
|
4月前
|
存储 分布式计算 分布式数据库
对给定的数据利用MapReduce编程实现数据的清洗和预处理,编程实现数据存储到HBase数据库,实现数据的增删改查操作接口
对给定的数据利用MapReduce编程实现数据的清洗和预处理,编程实现数据存储到HBase数据库,实现数据的增删改查操作接口
27 0
|
4月前
|
SQL 存储 NoSQL
分布式NoSQL列存储数据库Hbase操作(二)
分布式NoSQL列存储数据库Hbase操作(二)
114 0
|
5月前
|
分布式计算 分布式数据库 Hbase
99 MapReduce操作Hbase
99 MapReduce操作Hbase
42 0
|
7月前
|
Shell 分布式数据库 Hbase
Hbase shell管理操作
Hbase shell管理操作
53 0
|
8月前
|
Shell 分布式数据库 数据库
Hbase Shell操作
Hbase Shell操作
133 0
|
9月前
|
存储 Java Shell
分布式数据库HBase的常用操作的基本Shell命令的表操作
HBase是一个分布式数据库系统,支持高性能、可伸缩、实时的数据存储和处理。在HBase中,我们可以使用Shell命令来进行常用的操作,如创建表、插入数据、查询数据、更新数据等。本文将介绍关于分布式数据库HBase的常用操作基本Shell命令的表操作。
134 0