public interface DataPartitioner<I>
int
getPartitionNumberForInputRow(I item)
int getPartitionNumberForInputRow(I item)
item