Class EPDataFlowInstanceCaptive

java.lang.Object
com.espertech.esper.common.client.dataflow.core.EPDataFlowInstanceCaptive

public class EPDataFlowInstanceCaptive extends Object
Holder for captive data flow execution.
  • Constructor Details

    • EPDataFlowInstanceCaptive

      public EPDataFlowInstanceCaptive(Map<String,EPDataFlowEmitterOperator> emitters, List<com.espertech.esper.common.internal.epl.dataflow.runnables.GraphSourceRunnable> runnables)
      Ctor.
      Parameters:
      emitters - any emitters that are part of the data flow
      runnables - any runnables that represent source operators
  • Method Details

    • getEmitters

      public Map<String,EPDataFlowEmitterOperator> getEmitters()
      Map of named emitters.
      Returns:
      emitters
    • getRunnables

      public List<com.espertech.esper.common.internal.epl.dataflow.runnables.GraphSourceRunnable> getRunnables()
      List of operator source runnables.
      Returns:
      runnables