question: @ Override public void nextTuple ( ) { PartitionedEvent event = MockSampleMetadataFactory . createRandomOutOfTimeOrderEventGroupedByName ( "sampleStream_1" ) ; LOG . info ( "Receive {}" , event ) ; collector . emit ( outputStreamIds . get ( ( int ) ( event . getPartitionKey ( ) % outputStreamIds . size ( ) ) ) , Collections . singletonList ( event ) ) ; Utils . sleep ( 500 ) ; }
target:  This unit test is not to mock the end2end logic of correlation spout, but simply generate some sample data for following bolts testing