src/main/java/topology/ViperTopologyBuilder.java
// Otherwise, the merger is not needed...
Otherwise, the merger is not needed
Otherwise the merger is not needed
public void addParallelStatelessBolt(String id, IRichBolt bolt,
			Number parallelism_hint, String prevId, Fields prevFields, String tsField) {
		setBolt(id + "_merger", new ViperMerger(prevFields, tsField),
				parallelism_hint).customGrouping(prevId, new ViperShuffle());
		setBolt(id, bolt, parallelism_hint).directGrouping(id + "_merger");
	}
public void addParallelStatelessBolt ( String id , IRichBolt bolt , Number parallelism_hint , String prevId , Fields prevFields , String tsField ) { setBolt ( id + "_merger" , new ViperMerger ( prevFields , tsField ) , parallelism_hint ) . customGrouping ( prevId , new ViperShuffle ( ) ) ; setBolt ( id , bolt , parallelism_hint ) . directGrouping ( id + "_merger" ) ; }
Otherwise, the merger is not needed...
Otherwise the merger is not needed ...