SIRStream result = FuseSplit.fuse(toFuse); if (result==toFuse) { System.err.println("Rejected for fusion: " + toFuse); }
FusePipe.fuse((SIRPipeline)toFuse.get(0)); FusePipe.fuse((SIRPipeline)toFuse.get(1)); FuseSplit.fuse(toFuse);
    private static void doBigBeam1OnlyBottomSplit(SIRStream _str) {	SIRPipeline str = (SIRPipeline)_str;		StreamItDot.printGraph(str, "unbalanced.dot");	System.err.println("Working on the big beamform...");	FieldProp.doPropagate(str);	FuseAll.fuse(str);	// fuse hierarchical splitjoins	SIRSplitJoin sj = (SIRSplitJoin)str.get(1);	for (int i=0; i<sj.size(); i++) {	    SIRSplitJoin toFuse = (SIRSplitJoin)((SIRPipeline)(sj.get(i))).get(0);	    SIRStream result = FuseSplit.fuse(toFuse);	    if (result==toFuse) {		System.err.println("Rejected for fusion: " + toFuse);	    }	    FusePipe.fuse((SIRPipeline)sj.get(i));	}		/*	FuseSplit.fuse((SIRSplitJoin)str.get(1));	StreamItDot.printGraph(str, "1.dot");	FuseSplit.fuse((SIRSplitJoin)str.get(3));	FusePipe.fuse((SIRFilter)str.get(3),		      (SIRFilter)str.get(4));	*/	//ConstantProp.propagateAndUnroll(str);	//FieldProp.doPropagate(str);	StreamItDot.printGraph(str, "balanced.dot");	Namer.assignNames(str);    }