大橙子网站建设,新征程启航
为企业提供网站建设、域名注册、服务器等服务
本篇文章为大家展示了HDFS中addBlock函数的作用是什么,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
目前创新互联建站已为上千余家的企业提供了网站建设、域名、网站空间、网站运营、企业网站设计、涡阳网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。
public LocatedBlock addBlock(String src, String clientMachine) throws IOException {
int retries = 5;//设定重试次数为5
Object results[] = namesystem.getAdditionalBlock(new UTF8(src), new UTF8(clientMachine));
//获取新的一个Block和DataNode节点信息
while (results != null && results[0] == null && retries > 0) {
try {//发生错误,且不超过错误次数,就重新获取
Thread.sleep(100);
} catch (InterruptedException ie) {
}
results = namesystem.getAdditionalBlock(new UTF8(src), new UTF8(clientMachine));
retries--;
}
//无论如何,都结束了!
if (results == null) {//没找到?返回错误
throw new IOException("Cannot obtain additional block for file " + src);
} else if (results[0] == null) {
return null;//没有Block?返回null
} else {
Block b = (Block) results[0];
DatanodeInfo targets[] = (DatanodeInfo[]) results[1];
return new LocatedBlock(b, targets);//这个简单,返回Block和DatanodeInfo
}
}
=====================
C1:OKAY c2:OKAY c3:OKAY
=====================
下面开始讲解
public synchronized Object[] getAdditionalBlock(UTF8 src, UTF8 clientMachine) {
---
public synchronized Object[] getAdditionalBlock(UTF8 src, UTF8 clientMachine) {
Object results[] = null;
if (dir.getFile(src) == null && pendingCreates.get(src) != null) {
//文件系统dir中没有此文件且此文件正在创建过程中
results = new Object[2];//创建返回的变量数组
//
// If we fail this, bad things happen!
//这里的checkFileProgress很关键,
//后面会分析checkFileProgress的作用
if (checkFileProgress(src)) {
// Get the array of replication targets //这个仍然很简单,之前分析过了
DatanodeInfo targets[] = chooseTargets(this.desiredReplication, null, clientMachine);
if (targets.length < this.minReplication) {
return null;
}
// Create next block返回不多说!
results[0] = allocateBlock(src);
results[1] = targets;
}
}
return results;
}
===
接下来是函数
synchronized boolean checkFileProgress(UTF8 src) {
这个函数还是蛮重要的!
/**
* Check that the indicated file's blocks are present and
* replicated. If not, return false.
*/
synchronized boolean checkFileProgress(UTF8 src) {
Vector v = (Vector) pendingCreates.get(src);//获取文件名src对应的每个块
for (Iterator it = v.iterator(); it.hasNext(); ) {
Block b = (Block) it.next();//对于当前块来说
TreeSet containingNodes = (TreeSet) blocksMap.get(b);//获取这个块对应的datanode节点信息
if (containingNodes == null || containingNodes.size() < this.minReplication) {
return false;//如果此Block对应的datanode个数不足最小备份数,则禁止返回Block
}
}
return true;//顺利返回true.
}
上述内容就是HDFS中addBlock函数的作用是什么,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。