public class FileSplitPartitionQuery<K,T extends PersistentBase> extends PartitionQueryImpl<K,T>
FileSplit
to represent the partition boundaries.
FileSplitPartitionQuery is best used with existing InputFormat
s.baseQuery, locations
Constructor and Description |
---|
FileSplitPartitionQuery() |
FileSplitPartitionQuery(Query<K,T> baseQuery,
org.apache.hadoop.mapreduce.lib.input.FileSplit split) |
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) |
getBaseQuery, getDataStore, getEndTime, getFields, getFilter, getLimit, getLocations, getStartTime, getTimestamp, setEndTime, setFields, setFilter, setLimit, setStartTime, setTimeRange, setTimestamp
execute, getConf, getEndKey, getKey, getStartKey, hashCode, isLocalFilterEnabled, setConf, setDataStore, setEndKey, setKey, setKeyRange, setLocalFilterEnabled, setStartKey, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
execute, getEndKey, getKey, getStartKey, isLocalFilterEnabled, setDataStore, setEndKey, setKey, setKeyRange, setLocalFilterEnabled, setStartKey
public FileSplitPartitionQuery()
public FileSplitPartitionQuery(Query<K,T> baseQuery, org.apache.hadoop.mapreduce.lib.input.FileSplit split) throws IOException
IOException
public org.apache.hadoop.mapreduce.lib.input.FileSplit getSplit()
public long getLength()
public long getStart()
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class PartitionQueryImpl<K,T extends PersistentBase>
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class PartitionQueryImpl<K,T extends PersistentBase>
IOException
public boolean equals(Object obj)
equals
in class PartitionQueryImpl<K,T extends PersistentBase>
Copyright © 2010-2014 The Apache Software Foundation. All Rights Reserved.