JoinUtils.AvroIndexedRecordPartitioner (Apache Crunch 0.3.0-incubating API)

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

Overview

Package

Class

Use

Tree

Deprecated

Index

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.crunch.lib.join
Class JoinUtils.AvroIndexedRecordPartitioner<K,V>

java.lang.Object
  org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>
      org.apache.crunch.lib.join.JoinUtils.AvroIndexedRecordPartitioner<K,V>

Enclosing class:: JoinUtils

public static class JoinUtils.AvroIndexedRecordPartitioner<K,V>
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>
extends org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>

Constructor Summary

JoinUtils.AvroIndexedRecordPartitioner()

Method Summary

int getPartition(org.apache.avro.mapred.AvroKey<K> key, org.apache.avro.mapred.AvroValue<V> value, int numPartitions)

Methods inherited from class java.lang.Object

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

Constructor Summary
`JoinUtils.AvroIndexedRecordPartitioner()`

Method Summary
`int`	`getPartition(org.apache.avro.mapred.AvroKey<K> key, org.apache.avro.mapred.AvroValue<V> value, int numPartitions)`

Methods inherited from class java.lang.Object
`equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Constructor Detail

JoinUtils.AvroIndexedRecordPartitioner

public JoinUtils.AvroIndexedRecordPartitioner()

Method Detail

getPartition

public int getPartition(org.apache.avro.mapred.AvroKey<K> key,
                        org.apache.avro.mapred.AvroValue<V> value,
                        int numPartitions)

Specified by:: getPartition in class org.apache.hadoop.mapreduce.Partitioner<org.apache.avro.mapred.AvroKey<K>,org.apache.avro.mapred.AvroValue<V>>