StatelessPartitioner implements Partitioner<T>, Serializable { public int getPartitionCount() { return partitionCount; } StatelessPartitioner();  StatelessPartitioner(String value);  StatelessPartitioner(int partitionCount); void setPartitionCount(int partitionCount); int getPartitionCount(); @Override Collection<Partition<T>> definePartitions(Collection<Partition<T>> partitions, PartitioningContext context); @Override void partitioned(Map<Integer, Partition<T>> partitions); static Collection<Partition<T>> repartition(Collection<Partition<T>> partitions); static Collection<Partition<T>> repartitionInputOperator(Collection<Partition<T>> partitions); static Collection<Partition<T>> repartitionParallel(Collection<Partition<T>> partitions,
      PartitioningContext context);  }
@Test public void objectPropertyTest() { StringCodec<StatelessPartitioner<DummyOperator>> propertyReader = Object2String.getInstance(); StatelessPartitioner<DummyOperator> partitioner = propertyReader.fromString("com.datatorrent.common.partitioner.StatelessPartitioner:3"); Assert.assertEquals(3, partitioner.getPartitionCount()); }