return FuseSplit.fuse(self, childPart);
SIRStream result = FuseSplit.fuse(self, childPart);   if (result instanceof SIRPipeline) { FusePipe.fuse((SIRPipeline)result); } return result;
    public Object visitSplitJoin(SIRSplitJoin self,			  JFieldDeclaration[] fields,			  JMethodDeclaration[] methods,			  JMethodDeclaration init,			  SIRSplitter splitter,			  SIRJoiner joiner) {	//System.err.println("visiting " + self);	// build partition array based on orig children	int[] childPart = calcChildPartitions(self.getParallelStreams());	// replace children	replaceChildren(self);	// fuse	return FuseSplit.fuse(self, childPart);    }