oracle.kv.hadoop.table

Class TableInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

oracle.kv.hadoop.table.TableInputSplit

All Implemented Interfaces:

Writable

public class TableInputSplit
extends InputSplit
implements Writable

Concrete implementation of the InputSplit interface required to perform Hadoop MapReduce. A RecordReader will take instances of this class, where each such instance corresponds to data stored in an Oracle NoSQL Database store, and use those instances to retrieve that data when performing the MapReduce job.

Since:

3.1

Constructor Summary

Constructors

Constructor and Description
TableInputSplit()

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
String[]	getKVHelperHosts() Returns a String array with elements of the form, ''; where each elment specifies the connection information for each of store's helper hosts.
String	getKVStoreName() Returns the name of the store containing the records associated with this split.
long	getLength() Get the size of the split, so that the input splits can be sorted by size.
String[]	getLocations() Get the list of nodes by name where the data for the split would be local.
String	getTableName()
int	hashCode()
void	readFields(DataInput in) Deserialize the fields of this object from in.
String	toString()
void	write(DataOutput out) Serialize the fields of this object to out.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TableInputSplit

public TableInputSplit()

Method Detail

getLength

public long getLength()

Get the size of the split, so that the input splits can be sorted by size.

Specified by:

getLength in class InputSplit

Returns:

the number of bytes in the split

getLocations

public String[] getLocations()

Get the list of nodes by name where the data for the split would be local. The locations do not need to be serialized.

Specified by:

getLocations in class InputSplit

Returns:

a new array of the node nodes.

Throws:

IOException

InterruptedException

getKVHelperHosts

public String[] getKVHelperHosts()

Returns a String array with elements of the form, ''; where each elment specifies the connection information for each of store's helper hosts. Note that this method must be public so that instances of Hive InputSplit classes can wrap and delegate to an instance of this class.

getKVStoreName

public String getKVStoreName()

Returns the name of the store containing the records associated with this split. Note that this method must be public so that instances of Hive InputSplit classes can wrap and delegate to an instance of this class.

getTableName

public String getTableName()

write

public void write(DataOutput out)
           throws IOException

Serialize the fields of this object to out.

Specified by:

write in interface Writable

Parameters:

out - DataOuput to serialize this object into.

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Deserialize the fields of this object from in.

For efficiency, implementations should attempt to re-use storage in the existing object where possible.

Specified by:

readFields in interface Writable

Parameters:

in - DataInput to deseriablize this object from.

Throws:

IOException

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object