org.apache.accumulo.server.tabletserver.log
Class MultiReader

java.lang.Object
  extended by org.apache.accumulo.server.tabletserver.log.MultiReader

public class MultiReader
extends Object

Provide simple Map.Reader methods over multiple Maps. Presently only supports next() and seek() and works on all the Map directories within a directory. The primary purpose of this class is to merge the results of multiple Reduce jobs that result in Map output files.


Constructor Summary
MultiReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, String directory)
           
 
Method Summary
 void close()
           
 boolean next(org.apache.hadoop.io.WritableComparable key, org.apache.hadoop.io.Writable val)
           
 boolean seek(org.apache.hadoop.io.WritableComparable key)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MultiReader

public MultiReader(org.apache.hadoop.fs.FileSystem fs,
                   org.apache.hadoop.conf.Configuration conf,
                   String directory)
            throws IOException
Throws:
IOException
Method Detail

next

public boolean next(org.apache.hadoop.io.WritableComparable key,
                    org.apache.hadoop.io.Writable val)
             throws IOException
Throws:
IOException

seek

public boolean seek(org.apache.hadoop.io.WritableComparable key)
             throws IOException
Throws:
IOException

close

public void close()
           throws IOException
Throws:
IOException


Copyright © 2013 Apache Accumulo Project. All Rights Reserved.