edu.yale.cs.hadoopdb.sms.connector
Class SMSInputSplit

java.lang.Object
  extended by edu.yale.cs.hadoopdb.connector.DBInputSplit
      extended by 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
           
 
Fields inherited from class edu.yale.cs.hadoopdb.connector.DBInputSplit
chunk, locations, relation
 
Constructor Summary
SMSInputSplit()
           
 
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 edu.yale.cs.hadoopdb.connector.DBInputSplit
getChunk, getLength, getLocations, getRelation, setChunk, setRelation
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

p

org.apache.hadoop.fs.Path p
Constructor Detail

SMSInputSplit

public SMSInputSplit()
Method Detail

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