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

      }   
                   
                private int maxBytesToConsume(long pos)    
                {   
                        return (int) Math.min(Integer.MAX_VALUE, end - pos);   
                 }   
                   
                @Override   
                public boolean nextKeyValue() throws IOException,   
                        InterruptedException {   
                    //下一组值   
                    //tips:以后在这种函数中最好不要有输出，费时   
                    //LOG.info("正在读取下一个，嘿嘿");   
                    if(null == key)   
                    {   
                        key = new IntWritable();   
                    }   
                    if(null == value)   
                    {   
                        value = new IntWritable();   
                    }   
                    Text nowline = new Text();//保存当前行的内容   
                    int readsize = in.readLine(nowline);   
                    //更新当前读取到位置   
                    pos += readsize;   
                   
                    //如果pos的值大于等于end，说明此分片已经读取完毕   
                    if(pos >= end)   
                    {   
                        more = false;   
                        return false;   
                    }   
                       
         &nbs

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