Closed muyannian closed 10 years ago
InputSplit inputSplit = context.getInputSplit(); Path filepath = ((FileSplit) inputSplit).getPath();
if(filepath!=null)
{
String pash=filepath.toString();
this.Index=pash.hashCode()%1000000;
if(this.Index<0)
{
this.Index*=-1;
}
}
之前是根据map的indexid进行的hash,但是 当map 数量发生变化的时候,hash规则就发生了变化。
目前修改为 根据map处理文件的路径 进行hash