class RebalancePartitioner extends StreamPartitioner<T> {

	@Override
	public int[] selectChannels(SerializationDelegate<StreamRecord<T>> record,
			int numberOfOutputChannels) {
		this.returnArray[0] = (this.returnArray[0] + 1) % numberOfOutputChannels;
		return this.returnArray;
	}

}