public abstract class DeserializerComparator<T> extends Configured implements RawComparator<T>
Modifier and Type | Field and Description |
---|---|
protected java.util.Comparator[] |
groupComparators |
protected java.lang.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(java.lang.Class[] types,
java.util.Comparator[] comparators) |
protected int |
compareTuples(java.util.Comparator[] comparators,
Tuple lhs,
Tuple rhs) |
static java.util.Comparator[] |
getFieldComparatorsFrom(Configuration conf,
java.lang.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, comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong
protected BufferedInputStream lhsBuffer
protected BufferedInputStream rhsBuffer
protected TupleSerialization tupleSerialization
protected HadoopTupleInputStream lhsStream
protected HadoopTupleInputStream rhsStream
protected java.lang.Class[] keyTypes
protected java.util.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 java.util.Comparator[] getFieldComparatorsFrom(Configuration conf, java.lang.String name)
protected final int compareTuples(java.util.Comparator[] comparators, Tuple lhs, Tuple rhs)
protected final int compareTuples(java.lang.Class[] types, java.util.Comparator[] comparators) throws java.io.IOException
java.io.IOException
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.