org.apache.gora.query.impl

Class FileSplitPartitionQuery<K,T extends PersistentBase>

java.lang.Object

org.apache.gora.query.impl.QueryBase<K,T>

org.apache.gora.query.impl.PartitionQueryImpl<K,T>

org.apache.gora.query.impl.FileSplitPartitionQuery<K,T>

All Implemented Interfaces:

PartitionQuery<K,T>, Query<K,T>, org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable

public class FileSplitPartitionQuery<K,T extends PersistentBase>
extends PartitionQueryImpl<K,T>

Keeps a FileSplit to represent the partition boundaries. FileSplitPartitionQuery is best used with existing InputFormats.

Field Summary

Fields inherited from class org.apache.gora.query.impl.PartitionQueryImpl

baseQuery, locations

Fields inherited from class org.apache.gora.query.impl.QueryBase

dataStore, endKey, endTime, fields, filter, limit, localFilterEnabled, queryString, startKey, startTime

Constructor Summary

Constructors

Constructor and Description
FileSplitPartitionQuery()
FileSplitPartitionQuery(Query<K,T> baseQuery, org.apache.hadoop.mapreduce.lib.input.FileSplit split)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object obj)
long	getLength()
org.apache.hadoop.mapreduce.lib.input.FileSplit	getSplit()
long	getStart()
void	readFields(DataInput in)
void	write(DataOutput out)

Methods inherited from class org.apache.gora.query.impl.PartitionQueryImpl

getBaseQuery, getDataStore, getEndTime, getFields, getFilter, getLimit, getLocations, getStartTime, getTimestamp, setEndTime, setFields, setFilter, setLimit, setStartTime, setTimeRange, setTimestamp

Methods inherited from class org.apache.gora.query.impl.QueryBase

execute, getConf, getEndKey, getKey, getStartKey, hashCode, isLocalFilterEnabled, setConf, setDataStore, setEndKey, setKey, setKeyRange, setLocalFilterEnabled, setStartKey, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.gora.query.Query

execute, getEndKey, getKey, getStartKey, isLocalFilterEnabled, setDataStore, setEndKey, setKey, setKeyRange, setLocalFilterEnabled, setStartKey

Constructor Detail

FileSplitPartitionQuery

public FileSplitPartitionQuery()

FileSplitPartitionQuery

public FileSplitPartitionQuery(Query<K,T> baseQuery,
                       org.apache.hadoop.mapreduce.lib.input.FileSplit split)
                        throws IOException

Throws:

IOException

Method Detail

getSplit

public org.apache.hadoop.mapreduce.lib.input.FileSplit getSplit()

getLength

public long getLength()

getStart

public long getStart()

write

public void write(DataOutput out)
           throws IOException

Specified by:

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

Overrides:

write in class PartitionQueryImpl<K,T extends PersistentBase>

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

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

Overrides:

readFields in class PartitionQueryImpl<K,T extends PersistentBase>

Throws:

IOException

equals

public boolean equals(Object obj)

Overrides:

equals in class PartitionQueryImpl<K,T extends PersistentBase>