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

org.apache.crunch.impl.spark
Class SparkPartitioner

java.lang.Object
  extended by org.apache.spark.Partitioner
      extended by 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


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