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 InputFormat
s.
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 interface org.apache.hadoop.conf.Configurable |
getConf, setConf |
FileSplitPartitionQuery
public FileSplitPartitionQuery()
FileSplitPartitionQuery
public FileSplitPartitionQuery(Query<K,T> baseQuery,
org.apache.hadoop.mapreduce.lib.input.FileSplit split)
throws IOException
- Throws:
IOException
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>
Copyright © 2010-2013 The Apache Software Foundation. All Rights Reserved.