#Java - Code Snippets for '#.Server'

#Java - Code Snippets for '#.Server' - 11 code snippet(s) found

Sample 1. Code Sample / Example / Snippet of org.apache.hadoop.hdfs.server.namenode.DatanodeDescriptor.BlockTargetPair

  public BlockCommand(int action, List<BlockTargetPair> blocktargetlist) {

    super(action);



    blocks = new Block[blocktargetlist.size()]; 

    targets = new DatanodeInfo[blocks.length][];

    for(int i = 0; i < blocks.length; i++) {

      BlockTargetPair p = blocktargetlist.get(i);

      blocks[i] = p.block;

      targets[i] = p.targets;

    }

  }

_{Like Feedback org.apache.hadoop.hdfs.server.namenode.DatanodeDescriptor.BlockTargetPair}

Sample 2. Usage of org.apache.hadoop.hdfs.server.namenode.FSEditLog.EditLogFileInputStream

EditLogFileInputStream edits =

new EditLogFileInputStream(getImageFile(sd, NameNodeFile.EDITS));

numEdits = FSEditLog.loadFSEdits(edits);

edits.close();

File editsNew = getImageFile(sd, NameNodeFile.EDITS_NEW);

if (editsNew.exists() && editsNew.length() > 0) {

edits = new EditLogFileInputStream(editsNew);

numEdits += FSEditLog.loadFSEdits(edits);

edits.close();

_{Like Feedback EditLogFileInputStream Apache Hadoop}

Sample 3. Usage of org.apache.hadoop.hdfs.server.namenode.NameNode

NameNode nn = (NameNode)context.getAttribute("name.node");

Configuration conf = new Configuration(

(Configuration)context.getAttribute("name.conf"));

UnixUserGroupInformation.saveToConf(conf,

UnixUserGroupInformation.UGI_PROPERTY_NAME, ugi);

return DFSClient.createNamenode(nn.getNameNodeAddress(), conf);

_{Like Feedback Apache Hadoop NameNode}

Sample 4. Example / Sample of import org.apache.hadoop.hdfs.server.namenode.DatanodeDescriptor.BlockTargetPair;

  public BlockCommand(int action, List<BlockTargetPair> blocktargetlist) {

    super(action);



    blocks = new Block[blocktargetlist.size()]; 

    targets = new DatanodeInfo[blocks.length][];

    for(int i = 0; i < blocks.length; i++) {

      BlockTargetPair p = blocktargetlist.get(i);

      blocks[i] = p.block;

      targets[i] = p.targets;

    }

  }

_{Like Feedback org.apache.hadoop.hdfs.server.namenode.DatanodeDescriptor.BlockTargetPair}

Sample 5. Code Sample / Example / Snippet of org.apache.hadoop.hdfs.server.namenode.NameNode

  protected ClientProtocol createNameNodeProxy(UnixUserGroupInformation ugi

      ) throws IOException {

    ServletContext context = getServletContext();

    NameNode nn = (NameNode)context.getAttribute("name.node");

    Configuration conf = new Configuration(

        (Configuration)context.getAttribute("name.conf"));

    UnixUserGroupInformation.saveToConf(conf,

        UnixUserGroupInformation.UGI_PROPERTY_NAME, ugi);

    return DFSClient.createNamenode(nn.getNameNodeAddress(), conf);

  }

_{Like Feedback org.apache.hadoop.hdfs.server.namenode.NameNode}

Sample 6. Code Sample / Example / Snippet of org.apache.hadoop.hdfs.server.namenode.FSNamesystem

  private void doMerge(CheckpointSignature sig) throws IOException {

    FSNamesystem namesystem = 

            new FSNamesystem(checkpointImage, conf);

    assert namesystem.dir.fsImage == checkpointImage;

    checkpointImage.doMerge(sig);

  }

_{Like Feedback org.apache.hadoop.hdfs.server.namenode.FSNamesystem}

Sample 7. Code Sample / Example / Snippet of org.apache.hadoop.hdfs.server.common.Storage.StorageDirectory

  public File getFsEditName() throws IOException {

    return getEditLog().getFsEditName();

  }



  File getFsTimeName() {

    StorageDirectory sd = null;

    for (Iterator<StorageDirectory> it = 

             dirIterator(); it.hasNext();)

      sd = it.next();

    return getImageFile(sd, NameNodeFile.TIME);

  }

_{Like Feedback org.apache.hadoop.hdfs.server.common.Storage.StorageDirectory}

Sample 8. Code Sample / Example / Snippet of org.apache.hadoop.hdfs.server.common.UpgradeStatusReport

  public String getUpgradeStatusText() {

    String statusText = "";

    try {

      UpgradeStatusReport status = 

        fsn.distributedUpgradeProgress(UpgradeAction.GET_STATUS);

      statusText = (status == null ? 

          "There are no upgrades in progress." :

            status.getStatusText(false));

    } catch(IOException e) {

      statusText = "Upgrade status unknown.";

    }

    return statusText;

  }

_{Like Feedback org.apache.hadoop.hdfs.server.common.UpgradeStatusReport}

Sample 9. Code Sample / Example / Snippet of org.apache.spark.network.server.TransportServerBootstrap

  public void beforeEach() throws IOException {

    TransportContext context =

      new TransportContext(conf, new ExternalShuffleBlockHandler(conf, null));

    TransportServerBootstrap bootstrap = new SaslServerBootstrap(conf,

        new TestSecretKeyHolder("my-app-id", "secret"));

    this.server = context.createServer(Arrays.asList(bootstrap));

  }

_{Like Feedback org.apache.spark.network.server.TransportServerBootstrap}

Sample 10. Code Sample / Example / Snippet of org.apache.spark.network.server.RpcHandler

  public void testNoSaslServer() {

    RpcHandler handler = new TestRpcHandler();

    TransportContext context = new TransportContext(conf, handler);

    clientFactory = context.createClientFactory(

      Lists.<TransportClientBootstrap>newArrayList(

        new SaslClientBootstrap(conf, "app-1", secretKeyHolder)));

    TransportServer server = context.createServer();

    try {

      clientFactory.createClient(TestUtils.getLocalHost(), server.getPort());

    } catch (Exception e) {

      assertTrue(e.getMessage(), e.getMessage().contains("Digest-challenge format violation"));

    } finally {

      server.close();

    }

  }

_{Like Feedback org.apache.spark.network.server.RpcHandler}

Sample 11. Code Sample / Example / Snippet of org.apache.spark.network.server.TransportServer

  public void testNoSaslServer() {

    RpcHandler handler = new TestRpcHandler();

    TransportContext context = new TransportContext(conf, handler);

    clientFactory = context.createClientFactory(

      Lists.<TransportClientBootstrap>newArrayList(

        new SaslClientBootstrap(conf, "app-1", secretKeyHolder)));

    TransportServer server = context.createServer();

    try {

      clientFactory.createClient(TestUtils.getLocalHost(), server.getPort());

    } catch (Exception e) {

      assertTrue(e.getMessage(), e.getMessage().contains("Digest-challenge format violation"));

    } finally {

      server.close();

    }

  }

_{Like Feedback org.apache.spark.network.server.TransportServer}

Search Java Code Snippets