org.apache.ignite.internal.processors.hadoop.impl.v2

Class HadoopV2Partitioner

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Partitioner

All Implemented Interfaces:

HadoopPartitioner

public class HadoopV2Partitioner
extends Object
implements HadoopPartitioner

Hadoop partitioner adapter for v2 API.

Constructor Summary

Constructors

Constructor and Description
HadoopV2Partitioner(Class<? extends Partitioner<?,?>> cls, Configuration conf)

Method Summary

Modifier and Type	Method and Description
int	partition(Object key, Object val, int parts)

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopV2Partitioner

public HadoopV2Partitioner(Class<? extends Partitioner<?,?>> cls,
                           Configuration conf)

Parameters:

cls - Hadoop partitioner class.

conf - Job configuration.

Method Detail

partition

public int partition(Object key,
                     Object val,
                     int parts)

Specified by:

partition in interface HadoopPartitioner