Examples of org.apache.hadoop.hdfs.protocol.ClientProxyRequests.CreateRequest

    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;


      @Override
      public void callTimed() throws Exception {
        proxyTClientProxyProtocol.create(new CreateRequest(metaInfo, ROOT + "newfilea-" + i++,
            metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true,
            (short) 1, 1024));
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
    results.write("  |  ");


    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;


      @Override
      public void callTimed() throws Exception {
        proxyClientProxyProtocol.create(new CreateRequest(metaInfo, ROOT + "newfileb-" + i++,
            metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true,
            (short) 1, 1024));
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
    results.write("  |  ");


    results.write(new MeanDevAccumulator().addResults(new TimedCallable() {
      private int i = 0;


      @Override
      public void callTimed() throws Exception {
        directClientProxyProtocol.create(new CreateRequest(metaInfo, ROOT + "newfilec-" + i++,
            metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true,
            (short) 1, 1024));
      }
    }, WARMUP_SAMPLES, MEASURED_SAMPLES).report());
    results.write("  |  ");

    MiniAvatarCluster.shutDownZooKeeper();
  }


  @TestImplementation(name = "create")
  public void create0(Path path) throws RemoteException {
    clientThrift.create(new CreateRequest(metaInfo, path.toString(),
        metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true, (short) 1,
        1024));
  }

        1024));
  }


  @TestImplementation(name = "create")
  public void create1(Path path) throws IOException {
    clientRPC.create(new CreateRequest(metaInfo, path.toString(),
        metaInfo.getOrigCaller().getUserName(), FsPermission.getDefault(), true, true, (short) 1,
        1024));
  }

Examples of org.apache.hadoop.hdfs.protocol.ClientProxyRequests.CreateRequest

Related Classes of org.apache.hadoop.hdfs.protocol.ClientProxyRequests.CreateRequest