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

org.apache.crunch.impl.spark
Class SparkPartitioner

java.lang.Object
  org.apache.spark.Partitioner
      org.apache.crunch.impl.spark.SparkPartitioner

All Implemented Interfaces:

Serializable

public class SparkPartitioner
extends org.apache.spark.Partitioner

See Also:

Serialized Form

Constructor Summary

SparkPartitioner(int numPartitions)

Method Summary

int	getPartition(Object key)
int	numPartitions()

Methods inherited from class org.apache.spark.Partitioner

defaultPartitioner

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SparkPartitioner

public SparkPartitioner(int numPartitions)

Method Detail

numPartitions

public int numPartitions()

Specified by:

numPartitions in class org.apache.spark.Partitioner

getPartition

public int getPartition(Object key)

Specified by:

getPartition in class org.apache.spark.Partitioner