com.marklogic.mapreduce

Class MarkLogicInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

com.marklogic.mapreduce.MarkLogicInputSplit

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class MarkLogicInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable

MarkLogic-based InputSplit, used to represent a group of records returned by MarkLogic server, and identify originating host.

Constructor Summary

Constructors

Constructor and Description
MarkLogicInputSplit()
MarkLogicInputSplit(long start, long length, BigInteger forestId, String hostName, List<ForestHost> replicas)

Method Summary

Modifier and Type	Method and Description
BigInteger	getForestId()
long	getLength()
String[]	getLocations()
List<ForestHost>	getReplicas()
long	getStart()
boolean	isLastSplit() Is this the last split?
void	readFields(DataInput in)
void	setForestId(BigInteger forestId)
void	setHostName(String[] hostName)
void	setLastSplit(boolean isLast)
void	setLength(long length)
void	setStart(long start)
String	toString()
void	write(DataOutput out)

Methods inherited from class org.apache.hadoop.mapreduce.InputSplit

getLocationInfo

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MarkLogicInputSplit

public MarkLogicInputSplit()

MarkLogicInputSplit

public MarkLogicInputSplit(long start,
                           long length,
                           BigInteger forestId,
                           String hostName,
                           List<ForestHost> replicas)

Method Detail

getLength

public long getLength()
               throws IOException,
                      InterruptedException

Specified by:

getLength in class org.apache.hadoop.mapreduce.InputSplit

Throws:

IOException

InterruptedException

isLastSplit

public boolean isLastSplit()

Is this the last split?

Returns:

True if this is the last split; false otherwise.

getLocations

public String[] getLocations()
                      throws IOException,
                             InterruptedException

Specified by:

getLocations in class org.apache.hadoop.mapreduce.InputSplit

Throws:

IOException

InterruptedException

getStart

public long getStart()

setStart

public void setStart(long start)

getForestId

public BigInteger getForestId()

setForestId

public void setForestId(BigInteger forestId)

setHostName

public void setHostName(String[] hostName)

setLength

public void setLength(long length)

setLastSplit

public void setLastSplit(boolean isLast)

getReplicas

public List<ForestHost> getReplicas()

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object