org.apache.crunch.impl.spark
Class SparkComparator
java.lang.Object
org.apache.crunch.impl.spark.SparkComparator
- All Implemented Interfaces:
- Serializable, Comparator<ByteArray>
public class SparkComparator
- extends Object
- implements Comparator<ByteArray>, Serializable
- See Also:
- Serialized Form
SparkComparator
public SparkComparator(GroupingOptions options,
PGroupedTableType ptype,
SparkRuntimeContext ctxt)
compare
public int compare(ByteArray s1,
ByteArray s2)
- Specified by:
compare
in interface Comparator<ByteArray>
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.