org.apache.sentry.core.common.utils.KeyValue类的使用及代码示例

x33g5p2x  于2022-01-23 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(68)

本文整理了Java中org.apache.sentry.core.common.utils.KeyValue类的一些代码示例,展示了KeyValue类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。KeyValue类的具体详情如下:
包路径:org.apache.sentry.core.common.utils.KeyValue
类名称:KeyValue

KeyValue介绍

暂无

代码示例

代码示例来源:origin: apache/sentry

@Override
public List<KeyValue> getAuthorizable() {
 List<KeyValue> authorizable = new ArrayList<>();
 for (KeyValue part : parts) {
  // Authorizeable is the same as privileges but should exclude action
  if (!SentryConstants.PRIVILEGE_NAME.equalsIgnoreCase(part.getKey())) {
   KeyValue keyValue = new KeyValue(part.getKey().toLowerCase(),
     part.getValue().toLowerCase());
   authorizable.add(keyValue);
  }
 }
 return authorizable;
}

代码示例来源:origin: apache/sentry

public static SqoopAuthorizable from(KeyValue keyValue) {
 String prefix = keyValue.getKey().toLowerCase();
 String name = keyValue.getValue().toLowerCase();
 for (AuthorizableType type : AuthorizableType.values()) {
  if(prefix.equalsIgnoreCase(type.name())) {
   return from(type, name);
  }
 }
 return null;
}

代码示例来源:origin: apache/sentry

public static SolrModelAuthorizable from(String s) {
  return from(new KeyValue(s));
 }
}

代码示例来源:origin: apache/sentry

/**
 * Check if the action part in a privilege is ALL. Owner privilege is
 * treated as ALL for authorization
 * @param actionPart it must be the action of a privilege
 * @return true if the action is ALL; false otherwise
 */
private boolean isPrivilegeActionAll(KeyValue actionPart,
  BitFieldActionFactory bitFieldActionFactory) {
 return impliesAction(actionPart.getValue(), SentryConstants.PRIVILEGE_WILDCARD_VALUE,
   bitFieldActionFactory);
}

代码示例来源:origin: apache/sentry

public static IndexerModelAuthorizable from(KeyValue keyValue) {
 String prefix = keyValue.getKey().toLowerCase();
 String name = keyValue.getValue().toLowerCase();
 for(AuthorizableType type : AuthorizableType.values()) {
  if(prefix.equalsIgnoreCase(type.name())) {
   return from(type, name);
  }
 }
 return null;
}
public static IndexerModelAuthorizable from(String s) {

代码示例来源:origin: apache/sentry

public static KafkaAuthorizable from(String keyValue) throws ConfigurationException {
 return from(new KeyValue(keyValue));
}

代码示例来源:origin: apache/sentry

private List<? extends Authorizable> toAuthorizables(String privilegeStr) {
 List<Authorizable> authorizables = Lists.newArrayList();
 if (privilegeStr == null) {
  return authorizables;
 }
 for (String authorizable : SentryConstants.AUTHORIZABLE_SPLITTER.split(privilegeStr)) {
  KeyValue tempKV = new KeyValue(authorizable);
  final String key = tempKV.getKey();
  final String value = tempKV.getValue();
  authorizables.add(new Authorizable() {
   @Override
   public String getTypeName() {
    return key;
   }
   @Override
   public String getName() {
    return value;
   }
  });
 }
 return authorizables;
}

代码示例来源:origin: apache/sentry

public static KafkaAuthorizable from(KeyValue keyValue) throws ConfigurationException {
 String prefix = keyValue.getKey().toLowerCase();
 String name = keyValue.getValue();
 for (AuthorizableType type : AuthorizableType.values()) {
  if (prefix.equalsIgnoreCase(type.name())) {
   return from(type, name);
  }
 }
 return null;
}

代码示例来源:origin: apache/sentry

public static SqoopAuthorizable from(String keyValue) {
 return from(new KeyValue(keyValue));
}

代码示例来源:origin: apache/sentry

public CommonPrivilege(String privilegeStr) {
 privilegeStr = Strings.nullToEmpty(privilegeStr).trim();
 if (privilegeStr.isEmpty()) {
  throw new IllegalArgumentException("Privilege string cannot be null or empty.");
 }
 List<KeyValue> parts = Lists.newArrayList();
 for (String authorizable : SentryConstants.AUTHORIZABLE_SPLITTER.trimResults().split(
     privilegeStr)) {
  if (authorizable.isEmpty()) {
   throw new IllegalArgumentException("Privilege '" + privilegeStr + "' has an empty section");
  }
  parts.add(new KeyValue(authorizable));
 }
 if (parts.isEmpty()) {
  throw new AssertionError("Should never occur: " + privilegeStr);
 }
 // check if grant option is present
 KeyValue lastPart = parts.get(parts.size() - 1);
 if (lastPart.getKey().equalsIgnoreCase(SentryConstants.GRANT_OPTION)) {
  grantOption = lastPart.getValue().equalsIgnoreCase("true");
  parts.remove(parts.size() - 1);
 }
 this.parts = ImmutableList.copyOf(parts);
}

代码示例来源:origin: apache/sentry

public static DBModelAuthorizable from(KeyValue keyValue) {
 String prefix = keyValue.getKey().toLowerCase();
 String name = keyValue.getValue();
 for(AuthorizableType type : AuthorizableType.values()) {
  if(prefix.equalsIgnoreCase(type.name())) {
   if (prefix.equalsIgnoreCase(AuthorizableType.URI.toString())) {
    return from(type, name);
   } else {
    return from(type, name.toLowerCase());
   }
  }
 }
 return null;
}
public static DBModelAuthorizable from(String s) {

代码示例来源:origin: apache/sentry

public static DBModelAuthorizable from(String s) {
 return from(new KeyValue(s));
}

代码示例来源:origin: apache/sentry

String value;
try {
 kv = new KeyValue(kvStr);
 key = kv.getKey();
 value = kv.getValue();
} catch (Exception exception) {
 throw new SentryUserException("Wrongly formatted authorizable " + objectTrimmed);

代码示例来源:origin: apache/sentry

} else {
 KeyValue part = parts.get(index);
 String policyKey = part.getKey();
 if(!policyKey.equalsIgnoreCase(otherPart.getKey())) {
  if (!impliesAction(part.getValue(), otherPart.getValue(), model.getBitFieldActionFactory())) {
   return false;
      part.getValue(), otherPart.getValue())) {
   return false;

代码示例来源:origin: apache/sentry

public static IndexerModelAuthorizable from(String s) {
 return from(new KeyValue(s));
}

代码示例来源:origin: apache/sentry

public static TSentryPrivilege convertToTSentryPrivilege(String privilegeStr) {
 TSentryPrivilege tSentryPrivilege = new TSentryPrivilege();
 for (String authorizable : SentryConstants.AUTHORIZABLE_SPLITTER.split(privilegeStr)) {
  KeyValue tempKV = new KeyValue(authorizable);
  String key = tempKV.getKey();
  String value = tempKV.getValue();
  if (PolicyFileConstants.PRIVILEGE_SERVER_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setServerName(value);
  } else if (PolicyFileConstants.PRIVILEGE_DATABASE_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setDbName(value);
  } else if (PolicyFileConstants.PRIVILEGE_TABLE_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setTableName(value);
  } else if (PolicyFileConstants.PRIVILEGE_COLUMN_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setColumnName(value);
  } else if (PolicyFileConstants.PRIVILEGE_URI_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setURI(value);
  } else if (PolicyFileConstants.PRIVILEGE_ACTION_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setAction(value);
  } else if (PolicyFileConstants.PRIVILEGE_GRANT_OPTION_NAME.equalsIgnoreCase(key)) {
   TSentryGrantOption grantOption = "true".equalsIgnoreCase(value) ? TSentryGrantOption.TRUE
     : TSentryGrantOption.FALSE;
   tSentryPrivilege.setGrantOption(grantOption);
  }
 }
 tSentryPrivilege.setPrivilegeScope(getPrivilegeScope(tSentryPrivilege));
 return tSentryPrivilege;
}

代码示例来源:origin: apache/sentry

public static SolrModelAuthorizable from(KeyValue keyValue) {
 String prefix = keyValue.getKey().toLowerCase();
 String name = keyValue.getValue().toLowerCase();
 SolrModelAuthorizable result = null;
 for(AuthorizableType type : AuthorizableType.values()) {
  if(prefix.equalsIgnoreCase(type.name())) {
   switch (type) {
    case Collection:
     result = new Collection(name);
     break;
    case Admin:
     result = new AdminOperation(name);
     break;
    case Config:
     result = new Config(name);
     break;
    case Schema:
     result = new Schema(name);
     break;
    default:
     break;
   }
  }
 }
 return result;
}

代码示例来源:origin: apache/sentry

public TSentryPrivilege fromString(String privilegeStr) throws SentryUserException {
 privilegeStr = parsePrivilegeString(privilegeStr);
 if (validate) {
  validatePrivilegeHierarchy(privilegeStr);
 }
 TSentryPrivilege tSentryPrivilege = new TSentryPrivilege();
 List<TAuthorizable> authorizables = new LinkedList<TAuthorizable>();
 for (String authorizable : SentryConstants.AUTHORIZABLE_SPLITTER.split(privilegeStr)) {
  KeyValue keyValue = new KeyValue(authorizable);
  String key = keyValue.getKey();
  String value = keyValue.getValue();
  Authorizable authz = getAuthorizable(keyValue);
  if (authz != null) {
   authorizables.add(new TAuthorizable(authz.getTypeName(), authz.getName()));
  } else if (PolicyFileConstants.PRIVILEGE_ACTION_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setAction(value);
  } else {
   throw new IllegalArgumentException("Unknown key: " + key);
  }
 }
 if (tSentryPrivilege.getAction() == null) {
  throw new IllegalArgumentException("Privilege is invalid: action required but not specified.");
 }
 tSentryPrivilege.setComponent(component);
 tSentryPrivilege.setServiceName(service);
 tSentryPrivilege.setAuthorizables(authorizables);
 return tSentryPrivilege;
}

代码示例来源:origin: apache/sentry

public TSentryPrivilege fromString(String privilegeStr) throws SentryUserException {
 privilegeStr = parsePrivilegeString(privilegeStr);
 if (validate) {
  validatePrivilegeHierarchy(privilegeStr);
 }
 TSentryPrivilege tSentryPrivilege = new TSentryPrivilege();
 List<TAuthorizable> authorizables = new LinkedList<TAuthorizable>();
 for (String authorizable : SentryConstants.AUTHORIZABLE_SPLITTER.split(privilegeStr)) {
  KeyValue keyValue = new KeyValue(authorizable);
  String key = keyValue.getKey();
  String value = keyValue.getValue();
  Authorizable authz = getAuthorizable(keyValue);
  if (authz != null) {
   authorizables.add(new TAuthorizable(authz.getTypeName(), authz.getName()));
  } else if (PolicyFileConstants.PRIVILEGE_ACTION_NAME.equalsIgnoreCase(key)) {
   tSentryPrivilege.setAction(value);
  } else {
   throw new IllegalArgumentException("Unknown key: " + key);
  }
 }
 if (tSentryPrivilege.getAction() == null) {
  throw new IllegalArgumentException("Privilege is invalid: action required but not specified.");
 }
 tSentryPrivilege.setComponent(component);
 tSentryPrivilege.setServiceName(service);
 tSentryPrivilege.setAuthorizables(authorizables);
 return tSentryPrivilege;
}

相关文章

微信公众号

最新文章

更多