org.apache.hadoop.crypto.key.kms.KMSClientProvider.parseJSONMetadata()方法的使用及代码示例

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

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

KMSClientProvider.parseJSONMetadata介绍

暂无

代码示例

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

@Override
@SuppressWarnings("unchecked")
public Metadata[] getKeysMetadata(String ... keyNames) throws IOException {
 List<Metadata> keysMetadata = new ArrayList<Metadata>();
 List<String[]> keySets = createKeySets(keyNames);
 for (String[] keySet : keySets) {
  if (keyNames.length > 0) {
   Map<String, Object> queryStr = new HashMap<String, Object>();
   queryStr.put(KMSRESTConstants.KEY, keySet);
   URL url = createURL(KMSRESTConstants.KEYS_METADATA_RESOURCE, null,
     null, queryStr);
   HttpURLConnection conn = createConnection(url, HTTP_GET);
   List<Map> list = call(conn, null, HttpURLConnection.HTTP_OK, List.class);
   for (Map map : list) {
    keysMetadata.add(parseJSONMetadata(map));
   }
  }
 }
 return keysMetadata.toArray(new Metadata[keysMetadata.size()]);
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

@Override
@SuppressWarnings("unchecked")
public Metadata[] getKeysMetadata(String ... keyNames) throws IOException {
 List<Metadata> keysMetadata = new ArrayList<Metadata>();
 List<String[]> keySets = createKeySets(keyNames);
 for (String[] keySet : keySets) {
  if (keyNames.length > 0) {
   Map<String, Object> queryStr = new HashMap<String, Object>();
   queryStr.put(KMSRESTConstants.KEY, keySet);
   URL url = createURL(KMSRESTConstants.KEYS_METADATA_RESOURCE, null,
     null, queryStr);
   HttpURLConnection conn = createConnection(url, HTTP_GET);
   List<Map> list = call(conn, null, HttpURLConnection.HTTP_OK, List.class);
   for (Map map : list) {
    keysMetadata.add(parseJSONMetadata(map));
   }
  }
 }
 return keysMetadata.toArray(new Metadata[keysMetadata.size()]);
}

代码示例来源:origin: io.hops/hadoop-common

@Override
@SuppressWarnings("unchecked")
public Metadata[] getKeysMetadata(String ... keyNames) throws IOException {
 List<Metadata> keysMetadata = new ArrayList<Metadata>();
 List<String[]> keySets = createKeySets(keyNames);
 for (String[] keySet : keySets) {
  if (keyNames.length > 0) {
   Map<String, Object> queryStr = new HashMap<String, Object>();
   queryStr.put(KMSRESTConstants.KEY, keySet);
   URL url = createURL(KMSRESTConstants.KEYS_METADATA_RESOURCE, null,
     null, queryStr);
   HttpURLConnection conn = createConnection(url, HTTP_GET);
   List<Map> list = call(conn, null, HttpURLConnection.HTTP_OK, List.class);
   for (Map map : list) {
    keysMetadata.add(parseJSONMetadata(map));
   }
  }
 }
 return keysMetadata.toArray(new Metadata[keysMetadata.size()]);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

@Override
@SuppressWarnings("unchecked")
public Metadata[] getKeysMetadata(String ... keyNames) throws IOException {
 List<Metadata> keysMetadata = new ArrayList<Metadata>();
 List<String[]> keySets = createKeySets(keyNames);
 for (String[] keySet : keySets) {
  if (keyNames.length > 0) {
   Map<String, Object> queryStr = new HashMap<String, Object>();
   queryStr.put(KMSRESTConstants.KEY, keySet);
   URL url = createURL(KMSRESTConstants.KEYS_METADATA_RESOURCE, null,
     null, queryStr);
   HttpURLConnection conn = createConnection(url, HTTP_GET);
   List<Map> list = call(conn, null, HttpURLConnection.HTTP_OK, List.class);
   for (Map map : list) {
    keysMetadata.add(parseJSONMetadata(map));
   }
  }
 }
 return keysMetadata.toArray(new Metadata[keysMetadata.size()]);
}

代码示例来源:origin: io.prestosql.hadoop/hadoop-apache

@Override
public Metadata getMetadata(String name) throws IOException {
 checkNotEmpty(name, "name");
 URL url = createURL(KMSRESTConstants.KEY_RESOURCE, name,
   KMSRESTConstants.METADATA_SUB_RESOURCE, null);
 HttpURLConnection conn = createConnection(url, HTTP_GET);
 Map response = call(conn, null, HttpURLConnection.HTTP_OK, Map.class);
 return parseJSONMetadata(response);
}

代码示例来源:origin: com.github.jiayuhan-it/hadoop-common

@Override
public Metadata getMetadata(String name) throws IOException {
 checkNotEmpty(name, "name");
 URL url = createURL(KMSRESTConstants.KEY_RESOURCE, name,
   KMSRESTConstants.METADATA_SUB_RESOURCE, null);
 HttpURLConnection conn = createConnection(url, HTTP_GET);
 Map response = call(conn, null, HttpURLConnection.HTTP_OK, Map.class);
 return parseJSONMetadata(response);
}

代码示例来源:origin: io.hops/hadoop-common

@Override
public Metadata getMetadata(String name) throws IOException {
 checkNotEmpty(name, "name");
 URL url = createURL(KMSRESTConstants.KEY_RESOURCE, name,
   KMSRESTConstants.METADATA_SUB_RESOURCE, null);
 HttpURLConnection conn = createConnection(url, HTTP_GET);
 Map response = call(conn, null, HttpURLConnection.HTTP_OK, Map.class);
 return parseJSONMetadata(response);
}

代码示例来源:origin: ch.cern.hadoop/hadoop-common

@Override
public Metadata getMetadata(String name) throws IOException {
 checkNotEmpty(name, "name");
 URL url = createURL(KMSRESTConstants.KEY_RESOURCE, name,
   KMSRESTConstants.METADATA_SUB_RESOURCE, null);
 HttpURLConnection conn = createConnection(url, HTTP_GET);
 Map response = call(conn, null, HttpURLConnection.HTTP_OK, Map.class);
 return parseJSONMetadata(response);
}

相关文章

微信公众号

最新文章

更多