public class SequenceFileAccessor extends HdfsSplittableDataAccessor implements WriteAccessor
data, inputFormat, iter, jobConf, key, reader
Constructor and Description |
---|
SequenceFileAccessor(InputData input)
Constructs a SequenceFileAccessor.
|
Modifier and Type | Method and Description |
---|---|
void |
closeForWrite()
Closes the resource for write.
|
org.apache.hadoop.io.compress.CompressionCodec |
getCodec() |
org.apache.hadoop.io.SequenceFile.CompressionType |
getCompressionType() |
protected java.lang.Object |
getReader(org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.mapred.InputSplit split)
Overrides virtual method to create specialized record reader
|
boolean |
openForWrite()
Opens the resource for write.
|
boolean |
writeNextObject(OneRow onerow)
Writes the next object.
|
closeForRead, getNextSplit, isThreadSafe, openForRead, readNextObject
public SequenceFileAccessor(InputData input)
input
- all input parameters coming from the client requestprotected java.lang.Object getReader(org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.InputSplit split) throws java.io.IOException
getReader
in class HdfsSplittableDataAccessor
jobConf
- the hadoop jobconf to use for the selected InputFormatsplit
- the input split to be read by the accessorjava.io.IOException
- if recordreader could not be createdpublic boolean openForWrite() throws java.lang.Exception
WriteAccessor
openForWrite
in interface WriteAccessor
java.lang.Exception
- if opening the resource failedpublic boolean writeNextObject(OneRow onerow) throws java.io.IOException
WriteAccessor
writeNextObject
in interface WriteAccessor
onerow
- the object to be writtenjava.io.IOException
public void closeForWrite() throws java.lang.Exception
WriteAccessor
closeForWrite
in interface WriteAccessor
java.lang.Exception
- if closing the resource failedpublic org.apache.hadoop.io.SequenceFile.CompressionType getCompressionType()
public org.apache.hadoop.io.compress.CompressionCodec getCodec()