This project has retired. For details please refer to its Attic page.

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

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>