本文整理了Java中org.apache.hadoop.hdfs.server.datanode.DataNode.join()方法的一些代码示例，展示了DataNode.join()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。DataNode.join()方法的具体详情如下：
包路径：org.apache.hadoop.hdfs.server.datanode.DataNode
类名称：DataNode
方法名：join

DataNode.join介绍

暂无

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-hdfs

public static void secureMain(String args[], SecureResources resources) {
 int errorCode = 0;
 try {
  StringUtils.startupShutdownMessage(DataNode.class, args, LOG);
  DataNode datanode = createDataNode(args, null, resources);
  if (datanode != null) {
   datanode.join();
  } else {
   errorCode = 1;
  }
 } catch (Throwable e) {
  LOG.error("Exception in secureMain", e);
  terminate(1, e);
 } finally {
  // We need to terminate the process here because either shutdown was called
  // or some disk related conditions like volumes tolerated or volumes required
  // condition was not met. Also, In secure mode, control will go to Jsvc
  // and Datanode process hangs if it does not exit.
  LOG.warn("Exiting Datanode");
  terminate(errorCode);
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

/** Wait for the datanode to exit and clean up all its resources */
public void waitAndShutdown() {
 join();
 // make sure all other threads have exited even if 
 // offerservice thread died abnormally
 shutdown();
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

/**
 */
public static void main(String args[]) {
 try {
  StringUtils.startupShutdownMessage(DataNode.class, args, LOG);
  DataNode datanode = createDataNode(args, null);
  if (datanode != null)
   datanode.join();
 } catch (Throwable e) {
  LOG.error(StringUtils.stringifyException(e));
  System.exit(-1);
 }
}

代码示例来源：origin: io.fabric8/fabric-hadoop

public static void secureMain(String [] args, SecureResources resources) {
 try {
  StringUtils.startupShutdownMessage(DataNode.class, args, LOG);
  DataNode datanode = createDataNode(args, null, resources);
  if (datanode != null)
   datanode.join();
 } catch (Throwable e) {
  LOG.error(StringUtils.stringifyException(e));
  System.exit(-1);
 } finally {
  // We need to add System.exit here because either shutdown was called or
  // some disk related conditions like volumes tolerated or volumes required
  // condition was not met. Also, In secure mode, control will go to Jsvc and
  // the process hangs without System.exit.
  LOG.info("Exiting Datanode");
  System.exit(0);
 }
}

代码示例来源：origin: ch.cern.hadoop/hadoop-hdfs

public static void secureMain(String args[], SecureResources resources) {
 int errorCode = 0;
 try {
  StringUtils.startupShutdownMessage(DataNode.class, args, LOG);
  DataNode datanode = createDataNode(args, null, resources);
  if (datanode != null) {
   datanode.join();
  } else {
   errorCode = 1;
  }
 } catch (Throwable e) {
  LOG.fatal("Exception in secureMain", e);
  terminate(1, e);
 } finally {
  // We need to terminate the process here because either shutdown was called
  // or some disk related conditions like volumes tolerated or volumes required
  // condition was not met. Also, In secure mode, control will go to Jsvc
  // and Datanode process hangs if it does not exit.
  LOG.warn("Exiting Datanode");
  terminate(errorCode);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

public static void secureMain(String args[], SecureResources resources) {
 int errorCode = 0;
 try {
  StringUtils.startupShutdownMessage(DataNode.class, args, LOG);
  DataNode datanode = createDataNode(args, null, resources);
  if (datanode != null) {
   datanode.join();
  } else {
   errorCode = 1;
  }
 } catch (Throwable e) {
  LOG.fatal("Exception in secureMain", e);
  terminate(1, e);
 } finally {
  // We need to terminate the process here because either shutdown was called
  // or some disk related conditions like volumes tolerated or volumes required
  // condition was not met. Also, In secure mode, control will go to Jsvc
  // and Datanode process hangs if it does not exit.
  LOG.warn("Exiting Datanode");
  terminate(errorCode);
 }
}