org.apache.gora.mapreduce

Class GoraInputSplit

java.lang.Object

org.apache.hadoop.mapreduce.InputSplit

org.apache.gora.mapreduce.GoraInputSplit

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable

public class GoraInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.io.Writable, org.apache.hadoop.conf.Configurable

InputSplit using PartitionQuerys.

Field Summary

Fields

Modifier and Type	Field and Description
protected PartitionQuery<?,?>	query

Constructor Summary

Constructors

Constructor and Description
GoraInputSplit()
GoraInputSplit(org.apache.hadoop.conf.Configuration conf, PartitionQuery<?,?> query)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
org.apache.hadoop.conf.Configuration	getConf()
long	getLength()
String[]	getLocations()
PartitionQuery<?,?>	getQuery()
void	readFields(DataInput in)
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Field Detail

query

protected PartitionQuery<?,?> query

Constructor Detail

GoraInputSplit

public GoraInputSplit()

GoraInputSplit

public GoraInputSplit(org.apache.hadoop.conf.Configuration conf,
              PartitionQuery<?,?> query)

Method Detail

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable

getLength

public long getLength()
               throws IOException,
                      InterruptedException

Specified by:

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

Throws:

IOException

InterruptedException

getLocations

public String[] getLocations()

Specified by:

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

getQuery

public PartitionQuery<?,?> getQuery()

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

equals

public boolean equals(Object obj)

Overrides:

equals in class Object