GlobalPartitioner extends StreamPartitioner<T> { @Override public int[] selectChannels(SerializationDelegate<StreamRecord<T>> record, int numberOfOutputChannels) { return returnArray; }  @Override int[] selectChannels(SerializationDelegate<StreamRecord<T>> record,
			int numberOfOutputChannels); @Override StreamPartitioner<T> copy(); @Override String toString();  }
@Test public void testSelectChannels() { int[] result = new int[] { 0 }; sd.setInstance(streamRecord); assertArrayEquals(result, globalPartitioner.selectChannels(sd, 1)); assertArrayEquals(result, globalPartitioner.selectChannels(sd, 2)); assertArrayEquals(result, globalPartitioner.selectChannels(sd, 1024)); }