Package com.espertech.esper.runtime.internal.kernel.service

Class EPContextPartitionServiceImpl

java.lang.Object
com.espertech.esper.runtime.internal.kernel.service.EPContextPartitionServiceImpl
All Implemented Interfaces:
com.espertech.esper.common.client.context.EPContextPartitionService
public class EPContextPartitionServiceImpl extends Object implements com.espertech.esper.common.client.context.EPContextPartitionService

  • Constructor Details

    • EPContextPartitionServiceImpl

      public EPContextPartitionServiceImpl(EPServicesContext services)

  • Method Details

    • getContextStatementNames

      public String[] getContextStatementNames(String deploymentId, String contextName)
      Specified by:
      getContextStatementNames in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextNestingLevel

      public int getContextNestingLevel(String deploymentId, String contextName)
      Specified by:
      getContextNestingLevel in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextPartitions

      public com.espertech.esper.common.client.context.ContextPartitionCollection getContextPartitions(String deploymentId, String contextName, com.espertech.esper.common.client.context.ContextPartitionSelector selector)
      Specified by:
      getContextPartitions in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextPartitionIds

      public Set<Integer> getContextPartitionIds(String deploymentId, String contextName, com.espertech.esper.common.client.context.ContextPartitionSelector selector)
      Specified by:
      getContextPartitionIds in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextPartitionCount

      public long getContextPartitionCount(String deploymentId, String contextName)
      Specified by:
      getContextPartitionCount in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getIdentifier

      public com.espertech.esper.common.client.context.ContextPartitionIdentifier getIdentifier(String deploymentId, String contextName, int agentInstanceId)
      Specified by:
      getIdentifier in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • addContextStateListener

      public void addContextStateListener(com.espertech.esper.common.client.context.ContextStateListener listener)
      Specified by:
      addContextStateListener in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • removeContextStateListener

      public void removeContextStateListener(com.espertech.esper.common.client.context.ContextStateListener listener)
      Specified by:
      removeContextStateListener in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextStateListeners

      public Iterator<com.espertech.esper.common.client.context.ContextStateListener> getContextStateListeners()
      Specified by:
      getContextStateListeners in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • removeContextStateListeners

      public void removeContextStateListeners()
      Specified by:
      removeContextStateListeners in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • addContextPartitionStateListener

      public void addContextPartitionStateListener(String deploymentId, String contextName, com.espertech.esper.common.client.context.ContextPartitionStateListener listener)
      Specified by:
      addContextPartitionStateListener in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • removeContextPartitionStateListener

      public void removeContextPartitionStateListener(String deploymentId, String contextName, com.espertech.esper.common.client.context.ContextPartitionStateListener listener)
      Specified by:
      removeContextPartitionStateListener in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextPartitionStateListeners

      public Iterator<com.espertech.esper.common.client.context.ContextPartitionStateListener> getContextPartitionStateListeners(String deploymentId, String contextName)
      Specified by:
      getContextPartitionStateListeners in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • removeContextPartitionStateListeners

      public void removeContextPartitionStateListeners(String deploymentId, String contextName)
      Specified by:
      removeContextPartitionStateListeners in interface com.espertech.esper.common.client.context.EPContextPartitionService

    • getContextProperties

      public Map<String,Object> getContextProperties(String deploymentId, String contextName, int contextPartitionId)
      Specified by:
      getContextProperties in interface com.espertech.esper.common.client.context.EPContextPartitionService