Package org.apache.accumulo.hadoop.mapred

Class AccumuloRowInputFormat

java.lang.Object
org.apache.accumulo.hadoop.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 Object implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
Since:
2.0
See Also:

  • Constructor Summary

    Constructors
    Constructor
    Description
    AccumuloRowInputFormat()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static InputFormatBuilder.ClientParams<org.apache.hadoop.mapred.JobConf>
    configure()
    Sets all the information required for this map reduce job.
    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)
     
    org.apache.hadoop.mapred.InputSplit[]
    getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits)
    Gets the splits of the tables that have been set on the job by reading the metadata table for the specified ranges.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • AccumuloRowInputFormat

      public AccumuloRowInputFormat()

  • Method Details

    • getSplits

      public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf job, int numSplits) throws IOException
      Gets the splits of the tables that have been set on the job by reading the metadata table for the specified ranges.
      Specified by:
      getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
      Returns:
      the splits from the tables based on the ranges.
      Throws:
      IOException - if a table set on the job doesn't exist or an error occurs initializing the tablet locator

    • 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
      Specified by:
      getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>>
      Throws:
      IOException

    • configure

      public static InputFormatBuilder.ClientParams<org.apache.hadoop.mapred.JobConf> configure()
      Sets all the information required for this map reduce job.