System.err.println("Tried to fuse non-filter in SJ; returning original SJ.");
StreamItDot.printGraph(sj, "debug.dot"); System.err.println("Tried to fuse non-filter in SJ; returning original SJ: " + sj.getName());
    public static SIRStream fuse(SIRSplitJoin sj, PartitionGroup partition) {	{//Quick check	    Utils.assert(partition.getNumChildren()==sj.size(),			 "More children in partitioning than in splitjoin " + sj);	    for(int i=0;i<partition.size();i++) {		// if we're trying to fuse something that's not a filter, just return		if (partition.get(i)>1) {		    for (int j=partition.getFirst(i); j<=partition.getLast(i); j++) {			if (!(sj.get(j) instanceof SIRFilter)) {			    System.err.println("Tried to fuse non-filter in SJ; returning original SJ.");			    return sj;			}		    }		}	    }	}