import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void onSignal(EPDataFlowSignal signal) {
    if (iterate && signal instanceof EPDataFlowSignalFinalMarker) {
        Iterator<EventBean> it = selectResult.getFinalView().iterator();
        if (it != null) {
            for (;it.hasNext();) {
                EventBean event = it.next();
                if (submitEventBean) {
                    graphContext.submit(event);
                }
                else {
                    graphContext.submit(event.getUnderlying());
                }
            }
        }
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void onSignal(EPDataFlowSignal signal) {
    if (iterate && signal instanceof EPDataFlowSignalFinalMarker) {
        Iterator<EventBean> it = selectResult.getFinalView().iterator();
        if (it != null) {
            for (; it.hasNext(); ) {
                EventBean event = it.next();
                if (submitEventBean) {
                    graphContext.submit(event);
                } else {
                    graphContext.submit(event.getUnderlying());
                }
            }
        }
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void processSignal(EPDataFlowSignal signal) {
    if (signal instanceof EPDataFlowSignalFinalMarker) {
        if (runnable != null) {
            runnable.shutdown();
        }
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void processSignal(int operatorNum, EPDataFlowSignal signal) {
    List<DataFlowSignalListener> listeners = listenersPerOp.get(operatorNum);
    if (listeners == null || listeners.isEmpty()) {
        return;
    }
    for (DataFlowSignalListener listener : listeners) {
        listener.processSignal(signal);
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
@Override
public void handleSignal(EPDataFlowSignal signal) {
    try {
        handleSignalInternal(signal);
    } catch (InvocationTargetException ex) {
        log.error("Failed to invoke signal handler: " + ex.getMessage(), ex);
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void submitSignal(EPDataFlowSignal signal) {
    signalManager.processSignal(operatorNum, signal);
    for (SubmitHandler[] handlerArr : handlersPerStream) {
        for (SubmitHandler handler : handlerArr) {
            handler.handleSignal(signal);
        }
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
@Override
public void handleSignal(EPDataFlowSignal signal) {
    try {
        handleSignalInternal(signal);
    }
    catch (InvocationTargetException ex) {
        log.error("Failed to invoke signal handler: " + ex.getMessage(), ex);
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void onSignal(EPDataFlowSignal signal) {
    if (signal instanceof EPDataFlowSignalFinalMarker) {
        destroy();
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void onSignal(EPDataFlowSignal signal) {
    log.debug("Received punctuation, submitting totals: " + aggregate);
    graphContext.submit(aggregate);
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void submitSignal(EPDataFlowSignal signal) {
    dataFlowEmitter.submitSignal(signal);
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void submitSignal(EPDataFlowSignal signal) {
    queue.add(signal);
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void processSignal(EPDataFlowSignal signal) {
    if (signal instanceof EPDataFlowSignalFinalMarker) {
        shutdown = true;
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void onSignal(EPDataFlowSignal signal) {
    received.add(current);
    current = new ArrayList<T>();
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void onSignal(EPDataFlowSignal signal) {
    current.add(signal);
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void submitSignal(EPDataFlowSignal signal) {
    signalManager.processSignal(operatorNum, signal);
    for (SubmitHandler handler : targets) {
        handler.handleSignal(signal);
    }
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
protected void handleSignalInternal(EPDataFlowSignal signal) throws InvocationTargetException {
    fastMethod.invoke(target, new Object[]{signal});
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void submitSignal(EPDataFlowSignal signal) {
    signalManager.processSignal(operatorNum, signal);
    signalHandler.handleSignal(signal);
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void handleSignal(EPDataFlowSignal signal) {
    signalHandler.handleSignal(signal);
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
@Override
public void handleSignalInternal(EPDataFlowSignal signal) throws InvocationTargetException {
    fastMethod.invoke(target, new Object[]{streamNum, signal});
}
 

import com.espertech.esper.client.dataflow.EPDataFlowSignal; //导入依赖的package包/类
public void submitSignal(EPDataFlowSignal signal) {
    facility.submitSignal(signal);
}