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

Constructors

Constructor and Description
SparkComparator(GroupingOptions options, PGroupedTableType ptype, SparkRuntimeContext ctxt)

Method Summary

Modifier and Type	Method and Description
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

comparing, comparing, comparingDouble, comparingInt, comparingLong, equals, naturalOrder, nullsFirst, nullsLast, reversed, reverseOrder, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

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>