Hadoop FSDataInputStreamストリーム位置決めの例

  
  
  
  

   
   
   
   
/** 
   
   
   
   
 * 
   
   
   
   
 * Description:  Hadoop FSDataInputStream  
   
   
   
   
 * 
   
   
   
   
 * @author charles.wang 
   
   
   
   
 * @created Mar 13, 2012 9:21:34 AM 
   
   
   
   
 *  
   
   
   
   
 */ 
   
   
   
   
public class FileSystemCatSeekable { 
   
   
   
   
     
   
   
   
   
    public static void main(String [] args) throws Exception{ 
   
   
   
   
         
   
   
   
   
        //  
   
   
   
   
        String uri = args[0]; 
   
   
   
   
         
   
   
   
   
        Configuration conf = new Configuration(); 
   
   
   
   
        conf.set("hadoop.job.ugi", "root,root123"); 
   
   
   
   
         
   
   
   
   
         
   
   
   
   
        // Hadoop FileSystem ， FileSystem  
   
   
   
   
        FileSystem fs = FileSystem.get(URI.create(uri) ,conf); 
   
   
   
   
         
   
   
   
   
        // InputStream   
   
   
   
   
        FSDataInputStream in = null; 
   
   
   
   
         
   
   
   
   
        try{ 
   
   
   
   
         
   
   
   
   
        // FileSystem uri  
   
   
   
   
        in =fs.open(new Path (uri)); 
   
   
   
   
         
   
   
   
   
        //  
   
   
   
   
        IOUtils.copyBytes(in, System.out, 20, false); 
   
   
   
   
         
   
   
   
   
        //  
   
   
   
   
        in.seek(0); 
   
   
   
   
         
   
   
   
   
        //  
   
   
   
   
        IOUtils.copyBytes(in, System.out, 20, false); 
   
   
   
   
         
   
   
   
   
        }catch (Exception ex){ 
   
   
   
   
            ex.printStackTrace(); 
   
   
   
   
        }finally{ 
   
   
   
   
            in.close(); 
   
   
   
   
        } 
   
   
   
   
    } 
   
   
   
   
}