List of addBlock() Examples

Examples of addBlock()

Hexel.things.types.InventoryOwner.addBlock()
biz.source_code.miniTemplator.MiniTemplator.addBlock()
Adds an instance of a template block.
If the block contains variables, these variables must be set before the block is added. If the block contains subblocks (nested blocks), the subblocks must be added before this block is added. If multiple blocks exist with the specified name, an instance is added for each block occurrence. @param blockName the name of the block to be added. Case-insensitive. @param isOptional specifies whether an exception should be thrown when theblock does not exist in the template. If isOptional is false and the block does not exist, an exception is thrown. @throws BlockNotDefinedException when no block with the specified nameexists in the template and isOptional is false.
de.lv.jvoxgl.world.Chunk.addBlock()
Adds a Block to this Chunk @param block @param x @param y @param z
edu.mit.blocks.workspace.Page.addBlock()
@overrides WorkspaceWidget.addBlock()
jNab.core.protocol.Packet.addBlock()
jadx.core.dex.trycatch.ExceptionHandler.addBlock()
noop.model.Clazz.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.
org.apache.hadoop.hdfs.server.datanode.DataBlockScanner.addBlock()
Adds block to list of blocks
org.apache.hadoop.hdfs.server.namenode.AvatarNode.addBlock()
org.apache.hadoop.hdfs.server.namenode.NameNode.addBlock()
Stub for 0.20 clients that don't support HDFS-630
org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()
org.apache.tapestry5.internal.structure.ComponentPageElement.addBlock()
Used during the contruction of a page to add a non-anonymous Block to the component. @see ComponentResourcesCommon#getBlock(String)
org.geoserver.wms.decoration.MapDecorationLayout.addBlock()
Add a Block to the layout. @see {Block}
org.jacoco.core.analysis.MethodCoverage.addBlock()
Adds the given block to this method. @param instructions number of instructions of this block @param lines lines of this block @param covered true, if this block is covered

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

    Path fileWithEmptyBlock = new Path("/test/test/test4");
    fs.create(fileWithEmptyBlock);
    NamenodeProtocols nameNodeRpc = cluster.getNameNodeRpc();
    String clientName = fs.getClient().getClientName();
    // create one empty block
    nameNodeRpc.addBlock(fileWithEmptyBlock.toString(), clientName, null, null,
        INodeId.GRANDFATHER_INODE_ID, null);
    fs.createSnapshot(path, "s2");


    fs.rename(new Path("/test/test"), new Path("/test/test-renamed"));
    fs.delete(new Path("/test/test-renamed"), true);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        else
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    exceptionMsg);
      }
    };
    when(mockNN.addBlock(anyString(), 
                         anyString(),
                         any(ExtendedBlock.class),
                         any(DatanodeInfo[].class),
                         anyLong(), any(String[].class))).thenAnswer(answer);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        else
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    exceptionMsg);
      }
    };
    when(mockNN.addBlock(anyString(), 
                         anyString(),
                         any(ExtendedBlock.class),
                         any(DatanodeInfo[].class))).thenAnswer(answer);


    final DFSClient client = new DFSClient(null, mockNN, conf, null);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        else
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    exceptionMsg);
      }
    };
    when(mockNN.addBlock(anyString(), 
                         anyString(),
                         any(ExtendedBlock.class),
                         any(DatanodeInfo[].class))).thenAnswer(answer);


    final DFSClient client = new DFSClient(null, mockNN, conf, null);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        DatanodeDescriptor[] ret =
            (DatanodeDescriptor[]) invocation.callRealMethod();
        count++;
        if(count == 1) { // run second addBlock()
          LOG.info("Starting second addBlock for " + src);
          nn.addBlock(src, "clientName", null, null);
          LocatedBlocks lbs = nn.getBlockLocations(src, 0, Long.MAX_VALUE);
          assertEquals("Must be one block", 1, lbs.getLocatedBlocks().size());
          lb2 = lbs.get(0);
          assertEquals("Wrong replication",
              REPLICATION, lb2.getLocations().length);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        new EnumSetWritable<CreateFlag>(EnumSet.of(CreateFlag.CREATE)),
        true, (short)3, 1024);


    // start first addBlock()
    LOG.info("Starting first addBlock for " + src);
    nn.addBlock(src, "clientName", null, null);


    // check locations
    LocatedBlocks lbs = nn.getBlockLocations(src, 0, Long.MAX_VALUE);
    assertEquals("Must be one block", 1, lbs.getLocatedBlocks().size());
    lb1 = lbs.get(0);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        else
          throw new RemoteException(NotReplicatedYetException.class.getName(),
                                    exceptionMsg);
      }
    };
    when(mockNN.addBlock(anyString(), 
                         anyString(),
                         any(ExtendedBlock.class),
                         any(DatanodeInfo[].class))).thenAnswer(answer);


    final DFSClient client = new DFSClient(null, mockNN, conf, null);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        DatanodeStorageInfo[] ret =
            (DatanodeStorageInfo[]) invocation.callRealMethod();
        count++;
        if(count == 1) { // run second addBlock()
          LOG.info("Starting second addBlock for " + src);
          nn.addBlock(src, "clientName", null, null,
              INodeId.GRANDFATHER_INODE_ID, null);
          LocatedBlocks lbs = nn.getBlockLocations(src, 0, Long.MAX_VALUE);
          assertEquals("Must be one block", 1, lbs.getLocatedBlocks().size());
          lb2 = lbs.get(0);
          assertEquals("Wrong replication",

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

        new EnumSetWritable<CreateFlag>(EnumSet.of(CreateFlag.CREATE)),
        true, (short)3, 1024);


    // start first addBlock()
    LOG.info("Starting first addBlock for " + src);
    nn.addBlock(src, "clientName", null, null, INodeId.GRANDFATHER_INODE_ID, null);


    // check locations
    LocatedBlocks lbs = nn.getBlockLocations(src, 0, Long.MAX_VALUE);
    assertEquals("Must be one block", 1, lbs.getLocatedBlocks().size());
    lb1 = lbs.get(0);

View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.addBlock()

    nameNodeRpc.create(src, FsPermission.getFileDefault(), "clientName",
        new EnumSetWritable<CreateFlag>(EnumSet.of(CreateFlag.CREATE)), true,
        (short) 3, 1024);
    // start first addBlock()
    LOG.info("Starting first addBlock for " + src);
    LocatedBlock lb1 = nameNodeRpc.addBlock(src, "clientName", null, null,
        INodeId.GRANDFATHER_INODE_ID, null);
    assertTrue("Block locations should be present",
        lb1.getLocations().length > 0);


    cluster.restartNameNode();

View Full Code Here

0 1 2 3 4 5

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.