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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.OutputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<K,V>
          extended by org.apache.hadoop.mapreduce.lib.output.TextOutputFormat<org.apache.hadoop.io.WritableComparable,Tuple>
              extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextOutputFormat
                  extended by org.apache.pig.piggybank.storage.IndexedStorage.IndexedStorageOutputFormat
Enclosing class:
IndexedStorage

public static class IndexedStorage.IndexedStorageOutputFormat
extends PigTextOutputFormat

Internal OutputFormat class


Nested Class Summary
static class IndexedStorage.IndexedStorageOutputFormat.IndexedStorageRecordWriter
          Internal class to do the actual record writing and index generation
 
Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextOutputFormat
PigTextOutputFormat.PigLineRecordWriter
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.output.TextOutputFormat
org.apache.hadoop.mapreduce.lib.output.TextOutputFormat.LineRecordWriter<K,V>
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
org.apache.hadoop.mapreduce.lib.output.FileOutputFormat.Counter
 
Field Summary
protected  int[] offsetsToIndexKeys
          Offsets to index keys in given tuple
 
Fields inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
BASE_OUTPUT_NAME, PART
 
Constructor Summary
IndexedStorage.IndexedStorageOutputFormat(byte delimiter, int[] offsetsToIndexKeys)
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

offsetsToIndexKeys

protected final int[] offsetsToIndexKeys
Offsets to index keys in given tuple

Constructor Detail

IndexedStorage.IndexedStorageOutputFormat

public IndexedStorage.IndexedStorageOutputFormat(byte delimiter,
                                                 int[] offsetsToIndexKeys)
Method Detail

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable,Tuple> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                        throws IOException,
                                                                                                               InterruptedException
Overrides:
getRecordWriter in class PigTextOutputFormat
Throws:
IOException
InterruptedException


Copyright © 2007-2012 The Apache Software Foundation