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

DataNode.generateUuid介绍

暂无

代码示例

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

/**
 * Verify that the DatanodeUuid has been initialized. If this is a new
 * datanode then we generate a new Datanode Uuid and persist it to disk.
 *
 * @throws IOException
 */
synchronized void checkDatanodeUuid() throws IOException {
 if (storage.getDatanodeUuid() == null) {
  storage.setDatanodeUuid(generateUuid());
  storage.writeAll();
  LOG.info("Generated and persisted new Datanode UUID {}",
    storage.getDatanodeUuid());
 }
}

代码示例来源：origin: linkedin/dynamometer

public SimulatedMultiStorageFSDataset(DataNode datanode, Configuration conf) {
 super(datanode, null, conf);
 this.datanode = datanode;
 int storageCount = DataNode.getStorageLocations(conf).size();
 this.datanodeUuid = "SimulatedDatanode-" + DataNode.generateUuid();
 this.storages = new ArrayList<>();
 for (int i = 0; i < storageCount; i++) {
  this.storages.add(new SimulatedStorage(
    conf.getLong(CONFIG_PROPERTY_CAPACITY, DEFAULT_CAPACITY),
    conf.getEnum(CONFIG_PROPERTY_STATE, DEFAULT_STATE)));
 }
}

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

/**
 * Verify that the DatanodeUuid has been initialized. If this is a new
 * datanode then we generate a new Datanode Uuid and persist it to disk.
 *
 * @throws IOException
 */
private synchronized void checkDatanodeUuid() throws IOException {
 if (storage.getDatanodeUuid() == null) {
  storage.setDatanodeUuid(generateUuid());
  storage.writeAll();
  LOG.info("Generated and persisted new Datanode UUID " +
       storage.getDatanodeUuid());
 }
}

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

/**
 * Verify that the DatanodeUuid has been initialized. If this is a new
 * datanode then we generate a new Datanode Uuid and persist it to disk.
 *
 * @throws IOException
 */
private synchronized void checkDatanodeUuid() throws IOException {
 if (storage.getDatanodeUuid() == null) {
  storage.setDatanodeUuid(generateUuid());
  storage.writeAll();
  LOG.info("Generated and persisted new Datanode UUID " +
       storage.getDatanodeUuid());
 }
}

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

public SimulatedFSDataset(DataNode datanode, DataStorage storage, Configuration conf) {
 this.datanode = datanode;
 if (storage != null) {
  for (int i = 0; i < storage.getNumStorageDirs(); ++i) {
   DataStorage.createStorageID(storage.getStorageDir(i), false);
  }
  this.datanodeUuid = storage.getDatanodeUuid();
 } else {
  this.datanodeUuid = "SimulatedDatanode-" + DataNode.generateUuid();
 }
 registerMBean(datanodeUuid);
 this.storage = new SimulatedStorage(
   conf.getLong(CONFIG_PROPERTY_CAPACITY, DEFAULT_CAPACITY),
   conf.getEnum(CONFIG_PROPERTY_STATE, DEFAULT_STATE));
 this.volume = new SimulatedVolume(this.storage);
}

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

void register() throws IOException {
 // get versions from the namenode
 nsInfo = nameNodeProto.versionRequest();
 dnRegistration = new DatanodeRegistration(
   new DatanodeID(DNS.getDefaultIP("default"),
     DNS.getDefaultHost("default", "default"),
     DataNode.generateUuid(), getNodePort(dnIdx),
     DFSConfigKeys.DFS_DATANODE_HTTP_DEFAULT_PORT,
     DFSConfigKeys.DFS_DATANODE_HTTPS_DEFAULT_PORT,
     DFSConfigKeys.DFS_DATANODE_IPC_DEFAULT_PORT),
   new DataStorage(nsInfo),
   new ExportedBlockKeys(), VersionInfo.getVersion());
 // register datanode
 dnRegistration = dataNodeProto.registerDatanode(dnRegistration);
 dnRegistration.setNamespaceInfo(nsInfo);
 //first block reports
 storage = new DatanodeStorage(DatanodeStorage.generateUuid());
 final StorageBlockReport[] reports = {
   new StorageBlockReport(storage, BlockListAsLongs.EMPTY)
 };
 dataNodeProto.blockReport(dnRegistration, bpid, reports,
     new BlockReportContext(1, 0, System.nanoTime()));
}