1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.client;
19
20 import java.util.Map;
21
22 import org.apache.hadoop.hbase.classification.InterfaceAudience;
23 import org.apache.hadoop.hbase.classification.InterfaceStability;
24 import org.apache.hadoop.hbase.exceptions.DeserializationException;
25 import org.apache.hadoop.hbase.filter.Filter;
26 import org.apache.hadoop.hbase.protobuf.ProtobufUtil;
27 import org.apache.hadoop.hbase.security.access.AccessControlConstants;
28 import org.apache.hadoop.hbase.security.access.Permission;
29 import org.apache.hadoop.hbase.security.visibility.Authorizations;
30 import org.apache.hadoop.hbase.security.visibility.VisibilityConstants;
31
32 import com.google.common.collect.ArrayListMultimap;
33 import com.google.common.collect.ListMultimap;
34
35 @InterfaceAudience.Public
36 @InterfaceStability.Evolving
37 public abstract class Query extends OperationWithAttributes {
38 private static final String ISOLATION_LEVEL = "_isolationlevel_";
39 protected Filter filter = null;
40
41
42
43
44 public Filter getFilter() {
45 return filter;
46 }
47
48
49
50
51
52
53
54
55 public Query setFilter(Filter filter) {
56 this.filter = filter;
57 return this;
58 }
59
60
61
62
63
64 @InterfaceStability.Unstable
65 public void setAuthorizations(Authorizations authorizations) {
66 this.setAttribute(VisibilityConstants.VISIBILITY_LABELS_ATTR_KEY, ProtobufUtil
67 .toAuthorizations(authorizations).toByteArray());
68 }
69
70
71
72
73
74 @InterfaceStability.Unstable
75 public Authorizations getAuthorizations() throws DeserializationException {
76 byte[] authorizationsBytes = this.getAttribute(VisibilityConstants.VISIBILITY_LABELS_ATTR_KEY);
77 if (authorizationsBytes == null) return null;
78 return ProtobufUtil.toAuthorizations(authorizationsBytes);
79 }
80
81
82
83
84 @InterfaceStability.Unstable
85 public byte[] getACL() {
86 return getAttribute(AccessControlConstants.OP_ATTRIBUTE_ACL);
87 }
88
89
90
91
92
93 @InterfaceStability.Unstable
94 public void setACL(String user, Permission perms) {
95 setAttribute(AccessControlConstants.OP_ATTRIBUTE_ACL,
96 ProtobufUtil.toUsersAndPermissions(user, perms).toByteArray());
97 }
98
99
100
101
102 @InterfaceStability.Unstable
103 public void setACL(Map<String, Permission> perms) {
104 ListMultimap<String, Permission> permMap = ArrayListMultimap.create();
105 for (Map.Entry<String, Permission> entry : perms.entrySet()) {
106 permMap.put(entry.getKey(), entry.getValue());
107 }
108 setAttribute(AccessControlConstants.OP_ATTRIBUTE_ACL,
109 ProtobufUtil.toUsersAndPermissions(permMap).toByteArray());
110 }
111
112
113
114
115 @Deprecated
116 public boolean getACLStrategy() {
117 return false;
118 }
119
120
121
122
123 @Deprecated
124 public void setACLStrategy(boolean cellFirstStrategy) {
125 }
126
127
128
129
130
131
132
133
134
135
136
137
138 public void setIsolationLevel(IsolationLevel level) {
139 setAttribute(ISOLATION_LEVEL, level.toBytes());
140 }
141
142
143
144
145
146
147
148 public IsolationLevel getIsolationLevel() {
149 byte[] attr = getAttribute(ISOLATION_LEVEL);
150 return attr == null ? IsolationLevel.READ_COMMITTED :
151 IsolationLevel.fromBytes(attr);
152 }
153 }