class ForwardPartitioner extends StreamPartitioner<T> {

	@Override
	public int[] selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels) {
		return returnArray;
	}

}