This project has retired. For details please refer to its Attic page.
SparkComparator (Apache Crunch 0.11.0 API)

org.apache.crunch.impl.spark
Class SparkComparator

java.lang.Object
  extended by 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

Constructor Summary
SparkComparator(GroupingOptions options, PGroupedTableType ptype, SparkRuntimeContext ctxt)
           
 
Method Summary
 int compare(ByteArray s1, ByteArray s2)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.util.Comparator
equals
 

Constructor Detail

SparkComparator

public SparkComparator(GroupingOptions options,
                       PGroupedTableType ptype,
                       SparkRuntimeContext ctxt)
Method Detail

compare

public int compare(ByteArray s1,
                   ByteArray s2)
Specified by:
compare in interface Comparator<ByteArray>


Copyright © 2014 The Apache Software Foundation. All Rights Reserved.