775776777778779780781782783784785
if ( srcLeftTuples.getInsertFirst() != null ) { doLeftInserts( notNode, sink, bm, wm, srcLeftTuples, trgLeftTuples ); } srcRightTuples.resetAll(); srcLeftTuples.resetAll(); } public void doLeftInserts(NotNode notNode, LeftTupleSink sink,
13161317131813191320132113221323132413251326
if ( srcLeftTuples.getInsertFirst() != null ) { doLeftInserts( existsNode, sink, bm, wm, srcLeftTuples, trgLeftTuples ); } srcRightTuples.resetAll(); srcLeftTuples.resetAll( ); } public void doLeftInserts(ExistsNode existsNode, LeftTupleSink sink,
18521853185418551856185718581859186018611862
trgLeftTuples, stagedLeftTuples ); leftTuple.clearStaged(); leftTuple = next; } srcRightTuples.resetAll(); srcLeftTuples.resetAll(); } public void doLeftInserts(AccumulateNode accNode,
339340341342343344345346347348349
if ( srcLeftTuples.getInsertFirst() != null ) { doLeftInserts( joinNode, sink, bm, wm, srcLeftTuples, trgLeftTuples ); } srcRightTuples.resetAll(); srcLeftTuples.resetAll(); } public void doLeftInserts(JoinNode joinNode, LeftTupleSink sink,