public abstract class DeserializerComparator<T> extends Configured implements RawComparator<T>
Modifier and Type | Field and Description |
---|---|
protected Comparator[] |
groupComparators |
protected Class[] |
keyTypes |
protected BufferedInputStream |
lhsBuffer |
protected HadoopTupleInputStream |
lhsStream |
protected BufferedInputStream |
rhsBuffer |
protected HadoopTupleInputStream |
rhsStream |
protected TupleSerialization |
tupleSerialization |
Constructor and Description |
---|
DeserializerComparator() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
canPerformRawComparisons() |
protected int |
compareTuples(Class[] types,
Comparator[] comparators) |
protected int |
compareTuples(Comparator[] comparators,
Tuple lhs,
Tuple rhs) |
static Comparator[] |
getFieldComparatorsFrom(Configuration conf,
String name) |
protected HadoopTupleInputStream |
getHadoopTupleInputStream(BufferedInputStream lhsBuffer,
TupleSerialization.SerializationElementReader elementReader) |
protected boolean |
performRawComparison() |
void |
setConf(Configuration conf) |
getConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
compare
compare, equals
protected BufferedInputStream lhsBuffer
protected BufferedInputStream rhsBuffer
protected TupleSerialization tupleSerialization
protected HadoopTupleInputStream lhsStream
protected HadoopTupleInputStream rhsStream
protected Comparator[] groupComparators
public DeserializerComparator()
protected boolean canPerformRawComparisons()
protected boolean performRawComparison()
public void setConf(Configuration conf)
setConf
in interface Configurable
setConf
in class Configured
protected HadoopTupleInputStream getHadoopTupleInputStream(BufferedInputStream lhsBuffer, TupleSerialization.SerializationElementReader elementReader)
public static Comparator[] getFieldComparatorsFrom(Configuration conf, String name)
protected final int compareTuples(Comparator[] comparators, Tuple lhs, Tuple rhs)
protected final int compareTuples(Class[] types, Comparator[] comparators) throws IOException
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.