org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege.getHiveObject()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(90)

本文整理了Java中org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege.getHiveObject()方法的一些代码示例，展示了HiveObjectPrivilege.getHiveObject()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。HiveObjectPrivilege.getHiveObject()方法的具体详情如下：
包路径：org.apache.hadoop.hive.metastore.api.HiveObjectPrivilege
类名称：HiveObjectPrivilege
方法名：getHiveObject

HiveObjectPrivilege.getHiveObject介绍

暂无

代码示例

代码示例来源：origin: apache/hive

public Object getFieldValue(_Fields field) {
 switch (field) {
 case HIVE_OBJECT:
  return getHiveObject();
 case PRINCIPAL_NAME:
  return getPrincipalName();
 case PRINCIPAL_TYPE:
  return getPrincipalType();
 case GRANT_INFO:
  return getGrantInfo();
 case AUTHORIZER:
  return getAuthorizer();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: apache/hive

@Override
public boolean grant_privileges(PrivilegeBag privileges)
  throws MetaException, TException {
 String defaultCat = getDefaultCatalog(conf);
 for (HiveObjectPrivilege priv : privileges.getPrivileges()) {
  if (!priv.getHiveObject().isSetCatName()) {
   priv.getHiveObject().setCatName(defaultCat);
  }
 }
 GrantRevokePrivilegeRequest req = new GrantRevokePrivilegeRequest();
 req.setRequestType(GrantRevokeType.GRANT);
 req.setPrivileges(privileges);
 GrantRevokePrivilegeResponse res = client.grant_revoke_privileges(req);
 if (!res.isSetSuccess()) {
  throw new MetaException("GrantRevokePrivilegeResponse missing success field");
 }
 return res.isSuccess();
}

代码示例来源：origin: apache/hive

@Override
public boolean revoke_privileges(PrivilegeBag privileges, boolean grantOption) throws MetaException,
  TException {
 String defaultCat = getDefaultCatalog(conf);
 for (HiveObjectPrivilege priv : privileges.getPrivileges()) {
  if (!priv.getHiveObject().isSetCatName()) {
   priv.getHiveObject().setCatName(defaultCat);
  }
 }
 GrantRevokePrivilegeRequest req = new GrantRevokePrivilegeRequest();
 req.setRequestType(GrantRevokeType.REVOKE);
 req.setPrivileges(privileges);
 req.setRevokeGrantOption(grantOption);
 GrantRevokePrivilegeResponse res = client.grant_revoke_privileges(req);
 if (!res.isSetSuccess()) {
  throw new MetaException("GrantRevokePrivilegeResponse missing success field");
 }
 return res.isSuccess();
}

代码示例来源：origin: apache/hive

public static List<HivePrivilegeInfo> getPrivilegeInfos(List<HiveObjectPrivilege> privs)
  throws HiveException {
 List<HivePrivilegeInfo> hivePrivs = new ArrayList<HivePrivilegeInfo>();
 for (HiveObjectPrivilege priv : privs) {
  PrivilegeGrantInfo grantorInfo = priv.getGrantInfo();
  HiveObjectRef privObject = priv.getHiveObject();
  HivePrincipal hivePrincipal =
    getHivePrincipal(priv.getPrincipalName(), priv.getPrincipalType());
  HivePrincipal grantor =
    getHivePrincipal(grantorInfo.getGrantor(), grantorInfo.getGrantorType());
  HivePrivilegeObject object = getHiveObjectRef(privObject);
  HivePrivilege privilege = new HivePrivilege(grantorInfo.getPrivilege(), null);
  hivePrivs.add(new HivePrivilegeInfo(hivePrincipal, privilege, object, grantor,
    grantorInfo.isGrantOption(), grantorInfo.getCreateTime()));
 }
 return hivePrivs;
}

代码示例来源：origin: apache/hive

@Override
public boolean refresh_privileges(HiveObjectRef objToRefresh, String authorizer,
  PrivilegeBag grantPrivileges) throws MetaException,
  TException {
 String defaultCat = getDefaultCatalog(conf);
 objToRefresh.setCatName(defaultCat);
 if (grantPrivileges.getPrivileges() != null) {
  for (HiveObjectPrivilege priv : grantPrivileges.getPrivileges()) {
   if (!priv.getHiveObject().isSetCatName()) {
    priv.getHiveObject().setCatName(defaultCat);
   }
  }
 }
 GrantRevokePrivilegeRequest grantReq = new GrantRevokePrivilegeRequest();
 grantReq.setRequestType(GrantRevokeType.GRANT);
 grantReq.setPrivileges(grantPrivileges);
 GrantRevokePrivilegeResponse res = client.refresh_privileges(objToRefresh, authorizer, grantReq);
 if (!res.isSetSuccess()) {
  throw new MetaException("GrantRevokePrivilegeResponse missing success field");
 }
 return res.isSuccess();
}

代码示例来源：origin: apache/drill

public static List<HivePrivilegeInfo> getPrivilegeInfos(List<HiveObjectPrivilege> privs)
  throws HiveException {
 List<HivePrivilegeInfo> hivePrivs = new ArrayList<HivePrivilegeInfo>();
 for (HiveObjectPrivilege priv : privs) {
  PrivilegeGrantInfo grantorInfo = priv.getGrantInfo();
  HiveObjectRef privObject = priv.getHiveObject();
  HivePrincipal hivePrincipal =
    getHivePrincipal(priv.getPrincipalName(), priv.getPrincipalType());
  HivePrincipal grantor =
    getHivePrincipal(grantorInfo.getGrantor(), grantorInfo.getGrantorType());
  HivePrivilegeObject object = getHiveObjectRef(privObject);
  HivePrivilege privilege = new HivePrivilege(grantorInfo.getPrivilege(), null);
  hivePrivs.add(new HivePrivilegeInfo(hivePrincipal, privilege, object, grantor,
    grantorInfo.isGrantOption(), grantorInfo.getCreateTime()));
 }
 return hivePrivs;
}

代码示例来源：origin: apache/hive

while (privIter.hasNext()) {
 HiveObjectPrivilege privDef = privIter.next();
 HiveObjectRef hiveObject = privDef.getHiveObject();
 String privilegeStr = privDef.getGrantInfo().getPrivilege();
 String[] privs = privilegeStr.split(",");

代码示例来源：origin: apache/hive

@Override
public boolean refresh_privileges(HiveObjectRef objToRefresh, String authorizer,
  PrivilegeBag grantPrivileges) throws MetaException,
  TException {
 String defaultCat = getDefaultCatalog(conf);
 objToRefresh.setCatName(defaultCat);
 if (grantPrivileges.getPrivileges() != null) {
  for (HiveObjectPrivilege priv : grantPrivileges.getPrivileges()) {
   if (!priv.getHiveObject().isSetCatName()) {
    priv.getHiveObject().setCatName(defaultCat);
   }
  }
 }
 GrantRevokePrivilegeRequest grantReq = new GrantRevokePrivilegeRequest();
 grantReq.setRequestType(GrantRevokeType.GRANT);
 grantReq.setPrivileges(grantPrivileges);
 GrantRevokePrivilegeResponse res = client.refresh_privileges(objToRefresh, authorizer, grantReq);
 if (!res.isSetSuccess()) {
  throw new MetaException("GrantRevokePrivilegeResponse missing success field");
 }
 return res.isSuccess();
}

代码示例来源：origin: apache/hive

HiveObjectRef hiveObject = privDef.getHiveObject();
String privilegeStr = privDef.getGrantInfo().getPrivilege();
if (privilegeStr == null || privilegeStr.trim().equals("")) {

代码示例来源：origin: apache/hive

HiveObjectRef msObjRef = msObjPriv.getHiveObject();

代码示例来源：origin: apache/drill

HiveObjectRef msObjRef = msObjPriv.getHiveObject();

代码示例来源：origin: org.spark-project.hive/hive-metastore

public Object getFieldValue(_Fields field) {
 switch (field) {
 case HIVE_OBJECT:
  return getHiveObject();
 case PRINCIPAL_NAME:
  return getPrincipalName();
 case PRINCIPAL_TYPE:
  return getPrincipalType();
 case GRANT_INFO:
  return getGrantInfo();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: org.apache.hadoop.hive/hive-metastore

public Object getFieldValue(_Fields field) {
 switch (field) {
 case HIVE_OBJECT:
  return getHiveObject();
 case PRINCIPAL_NAME:
  return getPrincipalName();
 case PRINCIPAL_TYPE:
  return getPrincipalType();
 case GRANT_INFO:
  return getGrantInfo();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

public Object getFieldValue(_Fields field) {
 switch (field) {
 case HIVE_OBJECT:
  return getHiveObject();
 case PRINCIPAL_NAME:
  return getPrincipalName();
 case PRINCIPAL_TYPE:
  return getPrincipalType();
 case GRANT_INFO:
  return getGrantInfo();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: org.apache.hive/hive-standalone-metastore

public Object getFieldValue(_Fields field) {
 switch (field) {
 case HIVE_OBJECT:
  return getHiveObject();
 case PRINCIPAL_NAME:
  return getPrincipalName();
 case PRINCIPAL_TYPE:
  return getPrincipalType();
 case GRANT_INFO:
  return getGrantInfo();
 case AUTHORIZER:
  return getAuthorizer();
 }
 throw new IllegalStateException();
}

代码示例来源：origin: com.facebook.presto.hive/hive-apache

public static List<HivePrivilegeInfo> getPrivilegeInfos(List<HiveObjectPrivilege> privs)
  throws HiveException {
 List<HivePrivilegeInfo> hivePrivs = new ArrayList<HivePrivilegeInfo>();
 for (HiveObjectPrivilege priv : privs) {
  PrivilegeGrantInfo grantorInfo = priv.getGrantInfo();
  HiveObjectRef privObject = priv.getHiveObject();
  HivePrincipal hivePrincipal =
    getHivePrincipal(priv.getPrincipalName(), priv.getPrincipalType());
  HivePrincipal grantor =
    getHivePrincipal(grantorInfo.getGrantor(), grantorInfo.getGrantorType());
  HivePrivilegeObject object = getHiveObjectRef(privObject);
  HivePrivilege privilege = new HivePrivilege(grantorInfo.getPrivilege(), null);
  hivePrivs.add(new HivePrivilegeInfo(hivePrincipal, privilege, object, grantor,
    grantorInfo.isGrantOption(), grantorInfo.getCreateTime()));
 }
 return hivePrivs;
}

代码示例来源：origin: org.apache.hadoop.hive/hive-metastore

while (privIter.hasNext()) {
 HiveObjectPrivilege privDef = privIter.next();
 HiveObjectRef hiveObject = privDef.getHiveObject();
 String privilegeStr = privDef.getGrantInfo().getPrivilege();
 String[] privs = privilegeStr.split(",");

代码示例来源：origin: org.apache.hadoop.hive/hive-metastore

HiveObjectRef hiveObject = privDef.getHiveObject();
String privilegeStr = privDef.getGrantInfo().getPrivilege();
if (privilegeStr == null || privilegeStr.trim().equals("")) {

代码示例来源：origin: edu.berkeley.cs.shark/hive-metastore

HiveObjectRef hiveObject = privDef.getHiveObject();
String privilegeStr = privDef.getGrantInfo().getPrivilege();
if (privilegeStr == null || privilegeStr.trim().equals("")) {

代码示例来源：origin: com.facebook.presto.hive/hive-apache

HiveObjectRef msObjRef = msObjPriv.getHiveObject();

内容来源于网络，如有侵权，请联系作者删除！

HiveObjectPrivilege

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    HiveObjectPrivilege类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com