Package com.espertech.esper.common.client.dataflow.core

Class EPDataFlowInstantiationOptions

java.lang.Object
com.espertech.esper.common.client.dataflow.core.EPDataFlowInstantiationOptions
All Implemented Interfaces:
Serializable
public class EPDataFlowInstantiationOptions extends Object implements Serializable
Options for use when instantiating a data flow in EPDataFlowService.
See Also:

  • Constructor Details

    • EPDataFlowInstantiationOptions

      public EPDataFlowInstantiationOptions()

  • Method Details

    • getOperatorProvider

      public EPDataFlowOperatorProvider getOperatorProvider()
      Returns the operator provider.
      Returns:
      operator provider

    • operatorProvider

      public EPDataFlowInstantiationOptions operatorProvider(EPDataFlowOperatorProvider operatorProvider)
      Sets the the operator provider.
      Parameters:
      operatorProvider - operator provider
      Returns:
      this options object

    • setOperatorProvider

      public void setOperatorProvider(EPDataFlowOperatorProvider operatorProvider)
      Sets the the operator provider.
      Parameters:
      operatorProvider - operator provider

    • parameterProvider

      public EPDataFlowInstantiationOptions parameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)
      Sets the parameter provider.
      Parameters:
      parameterProvider - parameter provider
      Returns:
      this options object

    • getParameterProvider

      public EPDataFlowOperatorParameterProvider getParameterProvider()
      Returns the parameter provider.
      Returns:
      parameter provider

    • setParameterProvider

      public void setParameterProvider(EPDataFlowOperatorParameterProvider parameterProvider)
      Sets the parameter provider.
      Parameters:
      parameterProvider - parameter provider

    • getExceptionHandler

      public EPDataFlowExceptionHandler getExceptionHandler()
      Returns the exception handler.
      Returns:
      exception handler.

    • exceptionHandler

      public EPDataFlowInstantiationOptions exceptionHandler(EPDataFlowExceptionHandler exceptionHandler)
      Sets the exception handler.
      Parameters:
      exceptionHandler - exception handler.
      Returns:
      this options object

    • setExceptionHandler

      public void setExceptionHandler(EPDataFlowExceptionHandler exceptionHandler)
      Sets the exception handler.
      Parameters:
      exceptionHandler - exception handler.

    • getDataFlowInstanceId

      public String getDataFlowInstanceId()
      Returns the instance id assigned.
      Returns:
      instance if

    • dataFlowInstanceId

      public EPDataFlowInstantiationOptions dataFlowInstanceId(String dataFlowInstanceId)
      Sets the data flow instance id
      Parameters:
      dataFlowInstanceId - instance id
      Returns:
      this options object

    • setDataFlowInstanceId

      public void setDataFlowInstanceId(String dataFlowInstanceId)
      Sets the data flow instance id
      Parameters:
      dataFlowInstanceId - instance id

    • getDataFlowInstanceUserObject

      public Object getDataFlowInstanceUserObject()
      Returns the user object associated to the data flow instance.
      Returns:
      user object

    • dataFlowInstanceUserObject

      public EPDataFlowInstantiationOptions dataFlowInstanceUserObject(Object dataFlowInstanceUserObject)
      Sets the user object associated to the data flow instance.
      Parameters:
      dataFlowInstanceUserObject - user object
      Returns:
      this options object

    • setDataFlowInstanceUserObject

      public void setDataFlowInstanceUserObject(Object dataFlowInstanceUserObject)
      Sets the user object associated to the data flow instance.
      Parameters:
      dataFlowInstanceUserObject - this options object

    • isOperatorStatistics

      public boolean isOperatorStatistics()
      Returns indicator whether to collect operator statistics.
      Returns:
      operator stats indicator

    • operatorStatistics

      public EPDataFlowInstantiationOptions operatorStatistics(boolean statistics)
      Sets indicator whether to collect operator statistics.
      Parameters:
      statistics - operator stats indicator
      Returns:
      this options object

    • setOperatorStatistics

      public void setOperatorStatistics(boolean operatorStatistics)
      Sets indicator whether to collect operator statistics.
      Parameters:
      operatorStatistics - operator stats indicator

    • isCpuStatistics

      public boolean isCpuStatistics()
      Returns indicator whether to collect CPU statistics.
      Returns:
      CPU stats

    • setCpuStatistics

      public void setCpuStatistics(boolean cpuStatistics)
      Sets indicator whether to collect CPU statistics.
      Parameters:
      cpuStatistics - CPU stats

    • cpuStatistics

      public EPDataFlowInstantiationOptions cpuStatistics(boolean cpuStatistics)
      Sets indicator whether to collect CPU statistics.
      Parameters:
      cpuStatistics - CPU stats
      Returns:
      this options object

    • getSurrogateEventSender

      public com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped getSurrogateEventSender()
      Returns the event sender /runtime to use
      Returns:
      runtime.

    • setSurrogateEventSender

      public void setSurrogateEventSender(com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped surrogateEventSender)
      Sets the event sender /runtime to use
      Parameters:
      surrogateEventSender - runtime to use for sending

    • addParameterURI

      public void addParameterURI(String name, Object value)
      Add a parameter.
      Parameters:
      name - is the uri
      value - the value

    • getParametersURIs

      public Map<String,Object> getParametersURIs()
      Returns parameters.
      Returns:
      parameters

    • setParametersURIs

      public void setParametersURIs(Map<String,Object> parametersURIs)
      Sets parameters.
      Parameters:
      parametersURIs - map of name value pairs