org.apache.pig.piggybank.storage
Class IndexedStorage.IndexedStorageInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
          extended by org.apache.hadoop.mapreduce.lib.input.TextInputFormat
              extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextInputFormat
                  extended by org.apache.pig.piggybank.storage.IndexedStorage.IndexedStorageInputFormat
Enclosing class:
IndexedStorage

public static class IndexedStorage.IndexedStorageInputFormat
extends PigTextInputFormat

Internal InputFormat class


Nested Class Summary
static class IndexedStorage.IndexedStorageInputFormat.IndexedStorageRecordReader
          Internal RecordReader class
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
org.apache.hadoop.mapreduce.lib.input.FileInputFormat.Counter
 
Constructor Summary
IndexedStorage.IndexedStorageInputFormat()
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 boolean isSplitable(org.apache.hadoop.mapreduce.JobContext context, org.apache.hadoop.fs.Path filename)
           
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextInputFormat
listStatus
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

IndexedStorage.IndexedStorageInputFormat

public IndexedStorage.IndexedStorageInputFormat()
Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                                                org.apache.hadoop.mapreduce.TaskAttemptContext context)
Overrides:
createRecordReader in class org.apache.hadoop.mapreduce.lib.input.TextInputFormat

isSplitable

public boolean isSplitable(org.apache.hadoop.mapreduce.JobContext context,
                           org.apache.hadoop.fs.Path filename)
Overrides:
isSplitable in class org.apache.hadoop.mapreduce.lib.input.TextInputFormat


Copyright © 2007-2012 The Apache Software Foundation