This project has retired. For details please refer to its Attic page.

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

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 Persistent>
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, isCompiled, limit, queryString, startKey, startTime

Constructor Summary

FileSplitPartitionQuery()

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

Method Summary

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, getLimit, getLocations, getStartTime, getTimestamp, setEndTime, setFields, setLimit, setStartTime, setTimeRange, setTimestamp

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

execute, getConf, getEndKey, getKey, getStartKey, hashCode, setConf, setDataStore, setEndKey, setKey, setKeyRange, 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, setDataStore, setEndKey, setKey, setKeyRange, setStartKey

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

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 Persistent>

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 Persistent>

Throws:

IOException

equals

public boolean equals(Object obj)

Overrides:

equals in class PartitionQueryImpl<K,T extends Persistent>