SIRPipeline pipe = new SIRPipeline(sj.getParent(), "Wrapper_for_" + newFilter.getName(), JFieldDeclaration.EMPTY(), JMethodDeclaration.EMPTY());
SIRPipeline pipe = new SIRPipeline(sj.getParent(), newFilter.getName() + "_Wrap");
    private static SIRPipeline makeFusedPipe(SIRSplitJoin sj, 					     SRepInfo rep,					     SRate rate,					     SIRFilter newFilter) {	SIRPipeline pipe = new SIRPipeline(sj.getParent(), "Wrapper_for_" + newFilter.getName(),					   JFieldDeclaration.EMPTY(), JMethodDeclaration.EMPTY());	// make a dummy init function	pipe.setInit(SIRStream.makeEmptyInit());	// make a splitFilter only if it's not a duplicate and it's	// not a null split	if (sj.getSplitter().getType()!=SIRSplitType.DUPLICATE &&	    rep.splitter!=0) {	    pipe.add(makeFilter(sj.getParent(),				"Pre_" + sj.getIdent(),				makeSplitFilterBody(sj.getSplitter(), 						    rep,						    sj.getInputType()), 				rate.pop, rate.pop, rate.pop,				sj.getInputType()));	}		int index = sj.getParent().indexOf(sj);	Utils.assert(index>-1, "Couldn't find " + sj.getIdent() + " in " + sj.getParent().getIdent());	pipe.add(newFilter, new LinkedList(sj.getParent().getParams(index)));		// make a joinFilter only if it's not a not a null join	if (rep.joiner!=0) {	    pipe.add(makeFilter(sj.getParent(),				"Post_" + sj.getIdent(),				makeJoinFilterBody(sj.getJoiner(), 						   rep,						   sj.getOutputType()),				rate.push, rate.push, rate.push,				sj.getOutputType()));	}		return pipe;    }