public class WrapperSplit
extends org.apache.hadoop.mapred.FileSplit
implements org.apache.hadoop.io.Writable
Constructor and Description |
---|
WrapperSplit()
A parameter-less constructor for deserialization.
|
WrapperSplit(DocumentDBInputSplit wrappedSplit,
org.apache.hadoop.fs.Path file,
org.apache.hadoop.mapred.JobConf conf)
Create a split to wrap a given documentdb split.
|
Modifier and Type | Method and Description |
---|---|
DocumentDBInputSplit |
getWrappedSplit()
Returns the wrapped DocumentDBInputSplit instance.
|
void |
readFields(DataInput in) |
void |
write(DataOutput out) |
public WrapperSplit()
public WrapperSplit(DocumentDBInputSplit wrappedSplit, org.apache.hadoop.fs.Path file, org.apache.hadoop.mapred.JobConf conf)
wrappedSplit
- The split to wrap.file
- The file path for the partition in Hive (needs to match).conf
- The configuration.public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class org.apache.hadoop.mapred.FileSplit
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class org.apache.hadoop.mapred.FileSplit
IOException
public DocumentDBInputSplit getWrappedSplit()
Copyright © 2015. All rights reserved.