1. 包列表
  2. 类列表
  3. org.apache.hadoop.fs.swift.util.DurationStats

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

项目：hadoop    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：hadoop    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：aliyun-oss-hadoop-fs    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：aliyun-oss-hadoop-fs    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：big-c    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：big-c    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：hadoop-2.6.0-cdh5.4.3    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：hadoop-2.6.0-cdh5.4.3    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：hops    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：hops    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：hadoop-on-lustre2    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：hadoop-on-lustre2    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：sahara-extra    文件：TestSwiftRestClient.java    
@Test(timeout = SWIFT_TEST_TIMEOUT)
public void testPutAndDelete() throws Throwable {
  assumeEnabled();
  SwiftRestClient client = createClient();
  client.authenticate();
  Path path = new Path("restTestPutAndDelete");
  SwiftObjectPath sobject = SwiftObjectPath.fromPath(serviceURI, path);
  byte[] stuff = new byte[1];
  stuff[0] = 'a';
  client.upload(sobject, new ByteArrayInputStream(stuff), stuff.length);
  //check file exists
  Duration head = new Duration();
  Header[] responseHeaders = client.headRequest("expect success",
                                                sobject,
                                                SwiftRestClient.NEWEST);
  head.finished();
  LOG.info("head request duration " + head);
  for (Header header: responseHeaders) {
    LOG.info(header.toString());
  }
  //delete the file
  client.delete(sobject);
  //check file is gone
  try {
    Header[] headers = client.headRequest("expect fail",
                                          sobject,
                                          SwiftRestClient.NEWEST);
    Assert.fail("Expected deleted file, but object is still present: "
                + sobject);
  } catch (FileNotFoundException e) {
    //expected
  }
  for (DurationStats stats: client.getOperationStatistics()) {
    LOG.info(stats);
  }
}
项目：sahara-extra    文件：SwiftFileSystemBaseTest.java    
@AfterClass
public static void classTearDown() throws Exception {
  if (lastFs  != null) {
    List<DurationStats> statistics = lastFs.getOperationStatistics();
    for (DurationStats stat : statistics) {
      LOG.info(stat.toString());
    }
  }
}
项目：hadoop    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：aliyun-oss-hadoop-fs    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：big-c    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：hops    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：hadoop-on-lustre2    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：sahara-extra    文件：SwiftRestClient.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */

public List<DurationStats> getOperationStatistics() {
  return durationStats.getDurationStatistics();
}
项目：hadoop    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：hadoop    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}
项目：aliyun-oss-hadoop-fs    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：aliyun-oss-hadoop-fs    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}
项目：big-c    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：big-c    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：hadoop-2.6.0-cdh5.4.3    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}
项目：hops    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：hops    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}
项目：hadoop-on-lustre2    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：hadoop-on-lustre2    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}
项目：sahara-extra    文件：SwiftNativeFileSystem.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return store.getOperationStatistics();
}
项目：sahara-extra    文件：SwiftNativeFileSystemStore.java    
/**
 * Get the current operation statistics
 * @return a snapshot of the statistics
 */
public List<DurationStats> getOperationStatistics() {
  return swiftRestClient.getOperationStatistics();
}