java.lang.Object
com.espertech.esper.runtime.internal.dataflow.op.epstatementsource.EPStatementSourceFactory
All Implemented Interfaces:
com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory

public class EPStatementSourceFactory extends Object implements com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
  • Constructor Details

    • EPStatementSourceFactory

      public EPStatementSourceFactory()
  • Method Details

    • initializeFactory

      public void initializeFactory(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpFactoryInitializeContext context)
      Specified by:
      initializeFactory in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
    • operator

      public com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperator operator(com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOpInitializeContext context)
      Specified by:
      operator in interface com.espertech.esper.common.internal.epl.dataflow.interfaces.DataFlowOperatorFactory
    • setStatementName

      public void setStatementName(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator statementName)
    • setStatementFilter

      public void setStatementFilter(Map<String,Object> statementFilter)
    • setCollector

      public void setCollector(Map<String,Object> collector)
    • setSubmitEventBean

      public void setSubmitEventBean(boolean submitEventBean)
    • getStatementName

      public com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator getStatementName()
    • getStatementFilter

      public Map<String,Object> getStatementFilter()
    • getCollector

      public Map<String,Object> getCollector()
    • isSubmitEventBean

      public boolean isSubmitEventBean()
    • setStatementDeploymentId

      public void setStatementDeploymentId(com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator statementDeploymentId)