Class AccumuloRowInputFormat

java.lang.Object
org.apache.accumulo.core.client.mapred.AbstractInputFormat<K,V>
org.apache.accumulo.core.client.mapred.InputFormatBase<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
org.apache.accumulo.core.client.mapred.AccumuloRowInputFormat
All Implemented Interfaces:
org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>

public class AccumuloRowInputFormat extends InputFormatBase<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
This class allows MapReduce jobs to use Accumulo as the source of data. This InputFormat provides row names as Text as keys, and a corresponding PeekingIterator as a value, which in turn makes the Key/Value pairs for that row available to the Map function. The user must specify the following via static configurator methods: Other static methods are optional.
  • Constructor Details

    • AccumuloRowInputFormat

      public AccumuloRowInputFormat()
  • Method Details

    • getRecordReader

      public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>> getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf job, org.apache.hadoop.mapred.Reporter reporter) throws IOException
      Throws:
      IOException