RANGER-895: RangerHiveAuthorizer adds stub implementation of the new …

…methods in HiveAuthorizer
yzhou2001 · Mar 23, 2016 · 66c3034 · 66c3034
1 parent 9b1fa33
commit 66c3034
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 7 deletions.
diff --git a/...t/src/main/java/org/apache/ranger/authorization/hive/authorizer/RangerHiveAuthorizer.java b/...t/src/main/java/org/apache/ranger/authorization/hive/authorizer/RangerHiveAuthorizer.java
@@ -36,6 +36,7 @@
 import org.apache.hadoop.fs.permission.FsAction;
 import org.apache.hadoop.hive.common.FileUtils;
 import org.apache.hadoop.hive.conf.HiveConf;
+import org.apache.hadoop.hive.ql.parse.SemanticException;
 import org.apache.hadoop.hive.ql.security.HiveAuthenticationProvider;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAccessControlException;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthzContext;
@@ -459,6 +460,26 @@ public List<HivePrivilegeObject> filterListCmdObjects(List<HivePrivilegeObject>
 		return ret;
 	}
 
+	@Override
+	public String getRowFilterExpression(String databaseName, String tableOrViewName) throws SemanticException {
+		return null;
+	}
+
+	@Override
+	public boolean needTransform() {
+		return false;
+	}
+
+	@Override
+	public boolean needTransform(String databaseName, String tableOrViewName) {
+		return false;
+	}
+
+	@Override
+	public String getCellValueTransformer(String databaseName, String tableOrViewName, String columnName) throws SemanticException {
+		return columnName;
+	}
+
 	RangerHiveResource createHiveResource(HivePrivilegeObject privilegeObject) {
 		RangerHiveResource resource = null;
 

diff --git a/...c/main/java/org/apache/ranger/authorization/hive/authorizer/RangerHiveAuthorizerBase.java b/...c/main/java/org/apache/ranger/authorization/hive/authorizer/RangerHiveAuthorizerBase.java
@@ -28,7 +28,7 @@
 import org.apache.hadoop.hive.ql.security.HiveAuthenticationProvider;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.DisallowTransformHook;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAccessControlException;
-import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthorizer;
+import org.apache.hadoop.hive.ql.security.authorization.plugin.AbstractHiveAuthorizer;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthzPluginException;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthzSessionContext;
 import org.apache.hadoop.hive.ql.security.authorization.plugin.HiveAuthzSessionContext.CLIENT_TYPE;
@@ -41,7 +41,7 @@
 import org.apache.hadoop.security.UserGroupInformation;
 import org.apache.ranger.authorization.utils.StringUtil;
 
-public abstract class RangerHiveAuthorizerBase implements HiveAuthorizer {
+public abstract class RangerHiveAuthorizerBase extends AbstractHiveAuthorizer {
 
 	private static final Log LOG = LogFactory.getLog(RangerHiveAuthorizerBase.class);
 
@@ -217,10 +217,6 @@ public void setCurrentRole(String roleName)
 		throwNotImplementedException("setCurrentRole");
 	}
 
-	public  Object getHiveAuthorizationTranslator() throws HiveAuthzPluginException {
-		return null;
-	}
-
 	private void throwNotImplementedException(String method) throws HiveAuthzPluginException {
 		throw new HiveAuthzPluginException(method + "() not implemented in Ranger HiveAuthorizer");
 	}

diff --git a/pom.xml b/pom.xml
@@ -144,7 +144,7 @@
         <htrace-core.version>3.1.0-incubating</htrace-core.version>
         <hamcrest.all.version>1.3</hamcrest.all.version>
         <hbase.version>1.1.3</hbase.version>
-        <hive.version>1.2.0</hive.version>
+        <hive.version>2.1.0-SNAPSHOT</hive.version>
         <storm.version>0.9.2-incubating</storm.version>
         <httpcomponent.httpmime.version>4.2.5</httpcomponent.httpmime.version>
         <httpcomponent.httpclient.version>4.2.5</httpcomponent.httpclient.version>