org.apache.pig.piggybank.storage
Class IndexedStorage.IndexedStorageOutputFormat.IndexedStorageRecordWriter
java.lang.Object
org.apache.hadoop.mapreduce.RecordWriter<K,V>
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextOutputFormat.PigLineRecordWriter
org.apache.pig.piggybank.storage.IndexedStorage.IndexedStorageOutputFormat.IndexedStorageRecordWriter
- Enclosing class:
- IndexedStorage.IndexedStorageOutputFormat
public static class IndexedStorage.IndexedStorageOutputFormat.IndexedStorageRecordWriter
- extends PigTextOutputFormat.PigLineRecordWriter
Internal class to do the actual record writing and index generation
Method Summary |
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
|
void |
write(org.apache.hadoop.io.WritableComparable key,
Tuple value)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
IndexedStorage.IndexedStorageOutputFormat.IndexedStorageRecordWriter
public IndexedStorage.IndexedStorageOutputFormat.IndexedStorageRecordWriter(org.apache.hadoop.fs.FSDataOutputStream fileOut,
byte fieldDel,
IndexedStorage.IndexManager indexManager)
throws IOException
- Throws:
IOException
write
public void write(org.apache.hadoop.io.WritableComparable key,
Tuple value)
throws IOException
- Overrides:
write
in class PigTextOutputFormat.PigLineRecordWriter
- Throws:
IOException
close
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
throws IOException
- Throws:
IOException
Copyright © ${year} The Apache Software Foundation