Examples of org.apache.hadoop.hdfs.protocol.ClientProtocol.addBlock()

Class org.apache.hadoop.hdfs.protocol.ClientProtocol

Examples of org.apache.hadoop.hdfs.protocol.ClientProtocol.addBlock()

org.apache.hadoop.hdfs.protocol.ClientProtocol.addBlock()
A client that wants to write an additional block to the indicated filename (which must currently be open for writing) should call addBlock(). addBlock() allocates a new block and datanodes the block data should be replicated to. @deprecated use the 3-arg form below @return LocatedBlock allocated block information.

      for (int i = 0; i < partialLocs.length; i++) {
        partialLocs[i] = new DatanodeInfo(new DatanodeID(locs[i].getName()));
      }


      int slice = r.nextInt(locs.length);
      LocatedBlock dstlbk = srcNamenode.addBlock(dstFile, clientName, null,
          Arrays.copyOfRange(partialLocs, 0, slice + 1));
      List<DatanodeInfo>dstlocs = Arrays.asList(dstlbk.getLocations());
      assertEquals(conf.getInt("dfs.replication", 3), dstlocs.size());
      for (int i = 0; i <= slice; i++) {
        assertTrue("Expected " + locs[i].getName() + " was not found",

View Full Code Here

      for (int i = 0; i < partialLocs.length; i++) {
        partialLocs[i] = new DatanodeInfo(new DatanodeID(locs[i].getName()));
      }


      int slice = r.nextInt(locs.length);
      LocatedBlock dstlbk = srcNamenode.addBlock(dstFile, clientName, null,
          Arrays.copyOfRange(partialLocs, 0, slice + 1));
      List<DatanodeInfo>dstlocs = Arrays.asList(dstlbk.getLocations());
      assertEquals(conf.getInt("dfs.replication", 3), dstlocs.size());
      for (int i = 0; i <= slice; i++) {
        assertTrue("Expected " + locs[i].getName() + " was not found",

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.