public abstract class DeserializerComparator<T> extends Configured implements RawComparator<T>
Modifier and Type | Field and Description |
---|---|
protected Comparator[] |
groupComparators |
protected Class[] |
keyTypes |
protected cascading.tuple.hadoop.io.BufferedInputStream |
lhsBuffer |
protected cascading.tuple.hadoop.io.HadoopTupleInputStream |
lhsStream |
protected cascading.tuple.hadoop.io.BufferedInputStream |
rhsBuffer |
protected cascading.tuple.hadoop.io.HadoopTupleInputStream |
rhsStream |
protected cascading.tuple.hadoop.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 cascading.tuple.hadoop.io.HadoopTupleInputStream |
getHadoopTupleInputStream(cascading.tuple.hadoop.io.BufferedInputStream lhsBuffer,
cascading.tuple.hadoop.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 cascading.tuple.hadoop.io.BufferedInputStream lhsBuffer
protected cascading.tuple.hadoop.io.BufferedInputStream rhsBuffer
protected cascading.tuple.hadoop.TupleSerialization tupleSerialization
protected cascading.tuple.hadoop.io.HadoopTupleInputStream lhsStream
protected cascading.tuple.hadoop.io.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 cascading.tuple.hadoop.io.HadoopTupleInputStream getHadoopTupleInputStream(cascading.tuple.hadoop.io.BufferedInputStream lhsBuffer, cascading.tuple.hadoop.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.