java.lang.Object
com.espertech.esper.runtime.internal.dataflow.op.emitter.EmitterOp
All Implemented Interfaces:
com.espertech.esper.common.client.dataflow.core.EPDataFlowEmitterOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter

public class EmitterOp extends Object implements com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter, com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator, com.espertech.esper.common.client.dataflow.core.EPDataFlowEmitterOperator
  • Constructor Details

    • EmitterOp

      public EmitterOp(String name)
  • Method Details

    • submit

      public void submit(Object object)
      Specified by:
      submit in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter
      Specified by:
      submit in interface com.espertech.esper.common.client.dataflow.core.EPDataFlowEmitterOperator
    • submitSignal

      public void submitSignal(com.espertech.esper.common.client.dataflow.util.EPDataFlowSignal signal)
      Specified by:
      submitSignal in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter
      Specified by:
      submitSignal in interface com.espertech.esper.common.client.dataflow.core.EPDataFlowEmitterOperator
    • submitPort

      public void submitPort(int portNumber, Object object)
      Specified by:
      submitPort in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.EPDataFlowEmitter
      Specified by:
      submitPort in interface com.espertech.esper.common.client.dataflow.core.EPDataFlowEmitterOperator
    • getName

      public String getName()
      Specified by:
      getName in interface com.espertech.esper.common.client.dataflow.core.EPDataFlowEmitterOperator