Java 类org.apache.hadoop.fs.swift.util.JSONUtil 实例源码

项目：sahara-extra 文件：TestSwiftFileSystemDirectories.java

private String[] getRawObjectNames() throws Exception {
  SwiftRestClient client;
  client = SwiftRestClient.getInstance(fs.getUri(), fs.getConf());
  SwiftObjectPath path = SwiftObjectPath.fromPath(fs.getUri(), new Path("/"));
  byte[] bytes = client.listDeepObjectsInDirectory(path, true, true);
  final CollectionType collectionType = JSONUtil.getJsonMapper().
    getTypeFactory().constructCollectionType(List.class,
                                             SwiftObjectFileStatus.class);
  final List<SwiftObjectFileStatus> fileStatusList =
    JSONUtil.toObject(new String(bytes), collectionType);
  final ArrayList<String> objects = new ArrayList();
  for (SwiftObjectFileStatus status : fileStatusList) {
    if (status.getName() != null) {
      objects.add(status.getName());
    } else if (status.getSubdir() != null) {
      objects.add(status.getSubdir());
    }
  }
  return objects.toArray(new String[objects.size()]);
}

项目：hadoop 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：aliyun-oss-hadoop-fs 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：big-c 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hadoop-2.6.0-cdh5.4.3 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hops 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：hadoop-on-lustre2 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}

项目：sahara-extra 文件：SwiftRestClient.java

private StringRequestEntity getAuthenticationRequst(AuthenticationRequest authenticationRequest)
  throws IOException {
  final String data = JSONUtil.toJSON(new AuthenticationRequestWrapper(
          authenticationRequest));
  if (LOG.isDebugEnabled()) {
    LOG.debug("Authenticating with " + authenticationRequest);
  }
  return toJsonEntity(data);
}