oracle.spatial.hadoop.vector.nosql.mapreduce

Class NoSQLInputSplit

java.lang.Object

InputSplit

oracle.spatial.hadoop.vector.nosql.mapreduce.NoSQLInputSplit

Direct Known Subclasses:

NoSQLInputSplit

public class NoSQLInputSplit
extends InputSplit

An InputSplit containing the NoSQL partitions to be read and how to accces to these partitions

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
NoSQLInputSplit() Creates a new instance
NoSQLInputSplit(java.util.List<java.util.Set<java.lang.Integer>> partitionSets, java.lang.String[] kHosts, java.lang.String[] locations) Creates a new instance

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
java.lang.String[]	getKvHosts() Gets the KV hosts locations
long	getLength()
java.lang.String[]	getLocations()
java.util.List<java.util.Set<java.lang.Integer>>	getPartitionSets() Gets the partitions in this split
int	hashCode()
void	readFields(java.io.DataInput in)
void	setkHosts(java.lang.String[] kHosts) Sets the KV hosts locations
void	setLocations(java.lang.String[] locations)
void	setPartitionSets(java.util.List<java.util.Set<java.lang.Integer>> partitionSets) Sets the partitions in this split
java.lang.String	toString()
void	write(java.io.DataOutput out)

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

NoSQLInputSplit

public NoSQLInputSplit()

Creates a new instance

NoSQLInputSplit

public NoSQLInputSplit(java.util.List<java.util.Set<java.lang.Integer>> partitionSets,
                       java.lang.String[] kHosts,
                       java.lang.String[] locations)

Creates a new instance

Parameters:

partitionSets -

kHosts -

locations -

Method Detail

equals

public boolean equals(java.lang.Object obj)

getKvHosts

public java.lang.String[] getKvHosts()

Gets the KV hosts locations

Returns:

getLength

public long getLength()
               throws java.io.IOException,
                      java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getLocations

public java.lang.String[] getLocations()
                                throws java.io.IOException,
                                       java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getPartitionSets

public java.util.List<java.util.Set<java.lang.Integer>> getPartitionSets()

Gets the partitions in this split

Returns:

hashCode

public int hashCode()

readFields

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

Throws:

java.io.IOException

setkHosts

public void setkHosts(java.lang.String[] kHosts)

Sets the KV hosts locations

Parameters:

kHosts -

setLocations

public void setLocations(java.lang.String[] locations)

setPartitionSets

public void setPartitionSets(java.util.List<java.util.Set<java.lang.Integer>> partitionSets)

Sets the partitions in this split

Parameters:

partitionSets -

toString

public java.lang.String toString()

write

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

Throws:

java.io.IOException