Uses of Interface

Packages that use RecordReader
org.apache.hadoop.examples Hadoop example code. 
org.apache.hadoop.examples.terasort This package consists of 3 map/reduce applications for Hadoop to compete in the annual terabyte sort competition. 
org.apache.hadoop.mapred A software framework for easily writing applications which process vast amounts of data (multi-terabyte data-sets) parallelly on large clusters (thousands of nodes) built of commodity hardware in a reliable, fault-tolerant manner. 
org.apache.hadoop.mapred.join Given a set of sorted datasets keyed with the same class and yielding equal partitions, it is possible to effect a join of those datasets prior to the map. 
org.apache.hadoop.mapred.lib Library of generally useful mappers, reducers, and partitioners. 
org.apache.hadoop.mapred.lib.db org.apache.hadoop.mapred.lib.db Package 
org.apache.hadoop.streaming Hadoop Streaming is a utility which allows users to create and run Map-Reduce jobs with any executables (e.g. 

Uses of RecordReader in org.apache.hadoop.contrib.index.example

Classes in org.apache.hadoop.contrib.index.example that implement RecordReader
 class LineDocRecordReader
          A simple RecordReader for LineDoc for plain text files where each line is a doc.

Methods in org.apache.hadoop.contrib.index.example that return RecordReader
 RecordReader<DocumentID,LineDocTextAndOp> LineDocInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)

Uses of RecordReader in org.apache.hadoop.examples

Classes in org.apache.hadoop.examples that implement RecordReader
static class MultiFileWordCount.MultiFileLineRecordReader
          RecordReader is responsible from extracting records from the InputSplit.

Methods in org.apache.hadoop.examples that return RecordReader
 RecordReader<IntWritable,IntWritable> SleepJob.SleepInputFormat.getRecordReader(InputSplit ignored, JobConf conf, Reporter reporter)
 RecordReader<MultiFileWordCount.WordOffset,Text> MultiFileWordCount.MyInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)

Uses of RecordReader in org.apache.hadoop.examples.terasort

Methods in org.apache.hadoop.examples.terasort that return RecordReader
 RecordReader<Text,Text> TeraInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)

Uses of RecordReader in org.apache.hadoop.mapred

Classes in org.apache.hadoop.mapred that implement RecordReader
 class KeyValueLineRecordReader
          This class treats a line in the input as a key/value pair separated by a separator character.
 class LineRecordReader
          Treats keys as offset in file and value as line.
static class SequenceFileAsBinaryInputFormat.SequenceFileAsBinaryRecordReader
          Read records from a SequenceFile as binary (raw) bytes.
 class SequenceFileAsTextRecordReader
          This class converts the input keys and values to their String forms by calling toString() method.
 class SequenceFileRecordReader<K,V>
          An RecordReader for SequenceFiles.

Methods in org.apache.hadoop.mapred that return RecordReader
 RecordReader<K,V> InputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
          Get the RecordReader for the given InputSplit.
 RecordReader<BytesWritable,BytesWritable> SequenceFileAsBinaryInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
 RecordReader<K,V> SequenceFileInputFilter.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
          Create a record reader for the given split
 RecordReader<K,V> SequenceFileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
 RecordReader<LongWritable,Text> TextInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
 RecordReader<Text,Text> SequenceFileAsTextInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
abstract  RecordReader<K,V> FileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
 RecordReader<Text,Text> KeyValueTextInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
abstract  RecordReader<K,V> MultiFileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)

Methods in org.apache.hadoop.mapred with parameters of type RecordReader
 void<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)
          Start mapping input <key, value> pairs.
 void<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)

Uses of RecordReader in org.apache.hadoop.mapred.join

Subinterfaces of RecordReader in org.apache.hadoop.mapred.join
 interface ComposableRecordReader<K extends WritableComparable,V extends Writable>
          Additional operations required of a RecordReader to participate in a join.

Classes in org.apache.hadoop.mapred.join that implement RecordReader
 class InnerJoinRecordReader<K extends WritableComparable>
          Full inner join.
 class JoinRecordReader<K extends WritableComparable>
          Base class for Composite joins returning Tuples of arbitrary Writables.
 class MultiFilterRecordReader<K extends WritableComparable,V extends Writable>
          Base class for Composite join returning values derived from multiple sources, but generally not tuples.
 class OuterJoinRecordReader<K extends WritableComparable>
          Full outer join.
 class OverrideRecordReader<K extends WritableComparable,V extends Writable>
          Prefer the "rightmost" data source for this key.
 class WrappedRecordReader<K extends WritableComparable,U extends Writable>
          Proxy class for a RecordReader participating in the join framework.

Uses of RecordReader in org.apache.hadoop.mapred.lib

Classes in org.apache.hadoop.mapred.lib that implement RecordReader
 class CombineFileRecordReader<K,V>
          A generic RecordReader that can hand out different recordReaders for each chunk in a CombineFileSplit.

Fields in org.apache.hadoop.mapred.lib declared as RecordReader
protected  RecordReader<K,V> CombineFileRecordReader.curReader

Fields in org.apache.hadoop.mapred.lib with type parameters of type RecordReader
protected  Class<RecordReader<K,V>> CombineFileRecordReader.rrClass
protected  Constructor<RecordReader<K,V>> CombineFileRecordReader.rrConstructor

Methods in org.apache.hadoop.mapred.lib that return RecordReader
 RecordReader<K,V> DelegatingInputFormat.getRecordReader(InputSplit split, JobConf conf, Reporter reporter)
abstract  RecordReader<K,V> CombineFileInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
          This is not implemented yet.
 RecordReader<LongWritable,Text> NLineInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)

Methods in org.apache.hadoop.mapred.lib with parameters of type RecordReader
 void<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)

Constructor parameters in org.apache.hadoop.mapred.lib with type arguments of type RecordReader
CombineFileRecordReader(JobConf job, CombineFileSplit split, Reporter reporter, Class<RecordReader<K,V>> rrClass)
          A generic RecordReader that can hand out different recordReaders for each chunk in the CombineFileSplit.

Uses of RecordReader in org.apache.hadoop.mapred.lib.db

Classes in org.apache.hadoop.mapred.lib.db that implement RecordReader
protected  class DBInputFormat.DBRecordReader
          A RecordReader that reads records from a SQL table.

Methods in org.apache.hadoop.mapred.lib.db that return RecordReader
 RecordReader<LongWritable,T> DBInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
          Get the RecordReader for the given InputSplit.

Uses of RecordReader in org.apache.hadoop.streaming

Classes in org.apache.hadoop.streaming that implement RecordReader
 class StreamBaseRecordReader
          Shared functionality for hadoopStreaming formats.
 class StreamXmlRecordReader
          A way to interpret XML fragments as Mapper input records.

Methods in org.apache.hadoop.streaming that return RecordReader
 RecordReader<Text,Text> StreamInputFormat.getRecordReader(InputSplit genericSplit, JobConf job, Reporter reporter)
 RecordReader AutoInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)

Methods in org.apache.hadoop.streaming with parameters of type RecordReader
 void<K1,V1> input, OutputCollector<K2,V2> output, Reporter reporter)

Copyright © 2009 The Apache Software Foundation