com.nhncorp.neptune.parallel.hadoop
Class TableSplit

java.lang.Object
  com.nhncorp.neptune.parallel.hadoop.TableSplit

All Implemented Interfaces:

org.apache.hadoop.io.Writable, org.apache.hadoop.mapred.InputSplit

public class TableSplit
extends java.lang.Object
implements org.apache.hadoop.mapred.InputSplit

Table을 입력으로 MapReduce 작업을 수행할 때 사용하는 InputSplit

Author:

nhn

Constructor Summary

TableSplit()

TableSplit(java.lang.String tableName, Row.Key startRowKey, Row.Key endRowKey)

TableSplit(java.lang.String tableName, java.lang.String hostName, Row.Key startRowKey, Row.Key endRowKey)

Method Summary

Row.Key	getEndRowKey()
long	getLength()
java.lang.String[]	getLocations()
Row.Key	getStartRowKey()
java.lang.String	getTableName()
void	readFields(java.io.DataInput in)
java.lang.String	toString()
void	write(java.io.DataOutput out)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TableSplit

public TableSplit()

TableSplit

public TableSplit(java.lang.String tableName,
                  Row.Key startRowKey,
                  Row.Key endRowKey)

TableSplit

public TableSplit(java.lang.String tableName,
                  java.lang.String hostName,
                  Row.Key startRowKey,
                  Row.Key endRowKey)

Method Detail

getTableName

public java.lang.String getTableName()

getLength

public long getLength()

Specified by:

getLength in interface org.apache.hadoop.mapred.InputSplit

getLocations

public java.lang.String[] getLocations()

Specified by:

getLocations in interface org.apache.hadoop.mapred.InputSplit

readFields

public void readFields(java.io.DataInput in)
                throws java.io.IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

write

public void write(java.io.DataOutput out)
           throws java.io.IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getEndRowKey

public Row.Key getEndRowKey()

getStartRowKey

public Row.Key getStartRowKey()