Hi,
I have written below custom partition program in scala but it is not
calling partition method from producer
*class TestRoundRobinPartitioner(props: VerifiableProperties) extends
Partitioner { def partition(key: Any, numPartitions: Int): Int = {
println("key" + key); println("partition : " + numPartitions);
Integer.parseInt(key.toString())%4 }}*
In producer class I have configured this class
*props.put("partitioner.class", "TestRoundRobinPartitioner")*
Could you please help me to resolve this issue
Regards,
Rajesh
On Thu, May 7, 2015 at 12:38 PM, Madabhattula Rajesh Kumar <
[email protected]> wrote:
> Hi,
>
> Could you please point me the example scala program for Custom Partition
>
> Regards,
> Rajesh
>
