edu.yale.cs.hadoopdb.sms.connector
Class SMSInputSplit
java.lang.Object
edu.yale.cs.hadoopdb.connector.DBInputSplit
edu.yale.cs.hadoopdb.sms.connector.SMSInputSplit
- All Implemented Interfaces:
- org.apache.hadoop.hive.ql.io.Pathable, org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit
public class SMSInputSplit
- extends DBInputSplit
- implements org.apache.hadoop.hive.ql.io.Pathable
This class extends the base DBInputSplit class and additionally
serializes path information needed by Hive to rebuild map operators
from the data path being processed.
Field Summary |
static org.apache.commons.logging.Log |
LOG
|
(package private) org.apache.hadoop.fs.Path |
p
|
Method Summary |
org.apache.hadoop.fs.Path |
getPath()
Returns the internal path variable, called by HiveInputSplit |
void |
readFields(java.io.DataInput in)
readFields is used to deserialize information necessary to instantiate
the SMSInputSplit at Map nodes. |
void |
setPath(org.apache.hadoop.fs.Path p)
The path variable is set on calling getSplits in SMSInputFormat |
void |
write(java.io.DataOutput out)
write is used to serialize InputSplit information associated
with splits created by SMSInputFormat getSplits. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LOG
public static final org.apache.commons.logging.Log LOG
p
org.apache.hadoop.fs.Path p
SMSInputSplit
public SMSInputSplit()
getPath
public org.apache.hadoop.fs.Path getPath()
- Returns the internal path variable, called by HiveInputSplit
- Specified by:
getPath
in interface org.apache.hadoop.hive.ql.io.Pathable
- Returns:
- Path p
readFields
public void readFields(java.io.DataInput in)
throws java.io.IOException
- readFields is used to deserialize information necessary to instantiate
the SMSInputSplit at Map nodes. It first reads the path and
calls the DBInputSplit to deserialize remaining information.
- Specified by:
readFields
in interface org.apache.hadoop.io.Writable
- Overrides:
readFields
in class DBInputSplit
- Throws:
java.io.IOException
setPath
public void setPath(org.apache.hadoop.fs.Path p)
- The path variable is set on calling getSplits in SMSInputFormat
- Parameters:
p
- path
write
public void write(java.io.DataOutput out)
throws java.io.IOException
- write is used to serialize InputSplit information associated
with splits created by SMSInputFormat getSplits. SMSInputSplit
serializes Path information in addition to DBInputSplit information
- Specified by:
write
in interface org.apache.hadoop.io.Writable
- Overrides:
write
in class DBInputSplit
- Throws:
java.io.IOException