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

Class HadoopV1Partitioner

java.lang.Object

org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Partitioner

All Implemented Interfaces:

HadoopPartitioner

public class HadoopV1Partitioner
extends Object
implements HadoopPartitioner

Hadoop partitioner adapter for v1 API.

Constructor Summary

Constructors

Constructor and Description
HadoopV1Partitioner(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

HadoopV1Partitioner

public HadoopV1Partitioner(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