Changed class to accept RawComparator
git-svn-id: https://hyracks.googlecode.com/svn/trunk@56 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/hadoop/data/WritableComparingComparatorFactory.java b/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/hadoop/data/WritableComparingComparatorFactory.java
index bba68d5..6ef90b2 100644
--- a/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/hadoop/data/WritableComparingComparatorFactory.java
+++ b/hyracks/hyracks-dataflow-std/src/main/java/edu/uci/ics/hyracks/dataflow/std/hadoop/data/WritableComparingComparatorFactory.java
@@ -14,6 +14,7 @@
*/
package edu.uci.ics.hyracks.dataflow.std.hadoop.data;
+import org.apache.hadoop.io.RawComparator;
import org.apache.hadoop.io.WritableComparable;
import org.apache.hadoop.io.WritableComparator;
@@ -22,7 +23,7 @@
import edu.uci.ics.hyracks.dataflow.common.util.ReflectionUtils;
public class WritableComparingComparatorFactory<T> implements IComparatorFactory<WritableComparable<T>> {
- private Class<? extends WritableComparator> klass;
+ private Class<? extends RawComparator> klass;
public WritableComparingComparatorFactory(Class<? extends WritableComparator> klass) {
this.klass = klass;
@@ -32,7 +33,7 @@
@Override
public IComparator<WritableComparable<T>> createComparator() {
- final WritableComparator instance = ReflectionUtils.createInstance(klass);
+ final RawComparator<WritableComparable<T>> instance = ReflectionUtils.createInstance(klass);
return new IComparator<WritableComparable<T>>() {
@Override
public int compare(WritableComparable<T> o1, WritableComparable<T> o2) {