Hadoop自定义输出的代码 第5页

bsp;  
                }   
       
                @Override   
                public IntWritable getCurrentKey() throws IOException,   
                        InterruptedException {   
                    //得到当前的Key   
                    return key;   
                }   
       
                @Override   
                public IntWritable getCurrentValue() throws IOException,   
                        InterruptedException {   
                    //得到当前的value   
                    return value;   
                }   
       
                @Override   
                public float getProgress() throws IOException, InterruptedException {   
                    //计算对于当前片的处理进度   
                    if( false == more || end == start)   
                    {   
                        return 0f;   
                    }   
                    else   
                    {   
                        return Math.min(1.0f, (pos - start)/(end - start));   
                    }   
                }   
       
                @Override   
                public void close() throws IOException {   
                    //关闭此输入流   
                    if(null != in)   
                    {   
                        in.close();   
                    }   
       

上一页  [1] [2] [3] [4] [5] [6] [7] [8] [9] [10] 下一页