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

MarkLogicInputSplit()

MarkLogicInputSplit(long start, long length, BigInteger forestId, String hostName)

Method Summary

BigInteger	getForestId()
long	getLength()
String[]	getLocations()
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 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)

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)

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