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>>>

@Deprecated
public class AccumuloRowInputFormat
extends InputFormatBase<org.apache.hadoop.io.Text,​org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,​Value>>>
Deprecated.
since 2.0.0; Use org.apache.accumulo.hadoop.mapred instead from the accumulo-hadoop-mapreduce.jar
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()
      Deprecated.
  • 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
      Deprecated.
      Throws:
      IOException