@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);
}

@ 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 ) ; }
this unit test is not to mock the end2end logic of correlation spout , but simply generate some sample data for following bolts testing
