|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use EPServicesContext | |
---|---|
com.espertech.esper.core.context.activator | Activation of streams for statement start. |
com.espertech.esper.core.context.factory | Statement agent instance factories. |
com.espertech.esper.core.context.mgr | Context management. |
com.espertech.esper.core.context.subselect | Subselect implementation. |
com.espertech.esper.core.context.util | Context partition utility or reference classes. |
com.espertech.esper.core.service | Implementation of client package interfaces, glue code |
com.espertech.esper.core.start | Classes related to start and stop of statements |
com.espertech.esper.core.thread | This package contains classes to advanced threading options. |
com.espertech.esper.dataflow.core | Data flow core classes. |
com.espertech.esper.dataflow.interfaces | Data flow operator and related interface. |
com.espertech.esper.epl.metric | Services for metrics reporting, including global flag, repositories and threading. |
Uses of EPServicesContext in com.espertech.esper.core.context.activator |
---|
Methods in com.espertech.esper.core.context.activator that return EPServicesContext | |
---|---|
EPServicesContext |
ViewableActivatorFilterProxy.getServices()
|
Constructors in com.espertech.esper.core.context.activator with parameters of type EPServicesContext | |
---|---|
ViewableActivatorFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
java.lang.annotation.Annotation[] annotations,
boolean subSelect,
InstrumentationAgent instrumentationAgent,
boolean isCanIterate)
|
|
ViewableActivatorStreamReuseView(EPServicesContext services,
StatementContext statementContext,
StatementSpecCompiled statementSpec,
FilterStreamSpecCompiled filterStreamSpec,
boolean join,
ExprEvaluatorContextStatement evaluatorContextStmt,
boolean filterSubselectSameStream,
int streamNum,
boolean isCanIterateUnbound)
|
Uses of EPServicesContext in com.espertech.esper.core.context.factory |
---|
Fields in com.espertech.esper.core.context.factory declared as EPServicesContext | |
---|---|
protected EPServicesContext |
StatementAgentInstanceFactoryOnTriggerBase.services
|
Uses of EPServicesContext in com.espertech.esper.core.context.mgr |
---|
Methods in com.espertech.esper.core.context.mgr that return EPServicesContext | |
---|---|
EPServicesContext |
ContextControllerFactoryServiceContext.getServicesContext()
|
EPServicesContext |
ContextControllerFactoryContext.getServicesContext()
|
Methods in com.espertech.esper.core.context.mgr with parameters of type EPServicesContext | |
---|---|
void |
ContextManagementServiceImpl.addContextSpec(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
CreateContextDesc contextDesc,
boolean isRecoveringResilient)
|
void |
ContextManagementService.addContextSpec(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
CreateContextDesc contextDesc,
boolean isRecoveringResilient)
|
static ContextControllerCondition |
ContextControllerConditionFactory.getEndpoint(java.lang.String contextName,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
ContextDetailCondition endpoint,
ContextControllerConditionCallback callback,
ContextInternalFilterAddendum filterAddendum,
boolean isStartEndpoint,
int nestingLevel,
int pathId,
int subpathId)
|
Uses of EPServicesContext in com.espertech.esper.core.context.subselect |
---|
Methods in com.espertech.esper.core.context.subselect with parameters of type EPServicesContext | |
---|---|
SubSelectStrategyRealization |
SubSelectStrategyFactoryLocalViewPreloaded.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbackList)
|
SubSelectStrategyRealization |
SubSelectStrategyFactoryIndexShare.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbackList)
|
SubSelectStrategyRealization |
SubSelectStrategyFactory.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbackList)
|
Uses of EPServicesContext in com.espertech.esper.core.context.util |
---|
Methods in com.espertech.esper.core.context.util with parameters of type EPServicesContext | |
---|---|
static void |
StatementAgentInstanceUtil.evaluateEventForStatement(EPServicesContext servicesContext,
EventBean theEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.util.List<AgentInstance> agentInstances)
|
static boolean |
StatementAgentInstanceUtil.evaluateFilterForStatement(EPServicesContext servicesContext,
EventBean theEvent,
AgentInstanceContext agentInstanceContext,
FilterHandle filterHandle)
|
static void |
StatementAgentInstanceUtil.handleFilterFault(EventBean theEvent,
long version,
EPServicesContext servicesContext,
java.util.Map<java.lang.Integer,ContextControllerTreeAgentInstanceList> agentInstanceListMap)
|
static StatementAgentInstanceFactoryResult |
StatementAgentInstanceUtil.start(EPServicesContext servicesContext,
ContextControllerStatementBase statement,
boolean isSingleInstanceContext,
int agentInstanceId,
MappedEventBean agentInstanceProperties,
AgentInstanceFilterProxy agentInstanceFilterProxy,
boolean isRecoveringResilient)
|
static void |
StatementAgentInstanceUtil.stop(StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired)
|
static void |
StatementAgentInstanceUtil.stopAgentInstance(AgentInstance agentInstance,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired)
|
static void |
StatementAgentInstanceUtil.stopAgentInstances(java.util.List<AgentInstance> agentInstances,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired)
|
Uses of EPServicesContext in com.espertech.esper.core.service |
---|
Fields in com.espertech.esper.core.service declared as EPServicesContext | |
---|---|
protected EPServicesContext |
StatementLifecycleSvcImpl.services
Services context for statement lifecycle management. |
Methods in com.espertech.esper.core.service that return EPServicesContext | |
---|---|
EPServicesContext |
EPServicesContextFactoryDefault.createServicesContext(EPServiceProvider epServiceProvider,
ConfigurationInformation configSnapshot)
|
EPServicesContext |
EPServicesContextFactory.createServicesContext(EPServiceProvider epServiceProvider,
ConfigurationInformation configurationSnapshot)
Factory method for a new set of engine services. |
EPServicesContext |
EPAdministratorContext.getServices()
Returns the engine services context. |
EPServicesContext |
EPServiceProviderSPI.getServicesContext()
Returns services. |
EPServicesContext |
EPServiceProviderImpl.getServicesContext()
|
Methods in com.espertech.esper.core.service with parameters of type EPServicesContext | |
---|---|
protected static StatementSpecCompiled |
StatementLifecycleSvcImpl.compile(StatementSpecRaw spec,
java.lang.String eplStatement,
StatementContext statementContext,
boolean isSubquery,
boolean isOnDemandQuery,
java.lang.annotation.Annotation[] annotations,
java.util.List<ExprSubselectNode> subselectNodes,
java.util.List<ExprDeclaredNode> declaredNodes,
EPServicesContext servicesContext)
Compiles a statement returning the compile (verified, non-serializable) form of a statement. |
static StatementSpecRaw |
EPAdministratorHelper.compileEPL(java.lang.String eplStatement,
java.lang.String eplStatementForErrorMsg,
boolean addPleaseCheck,
java.lang.String statementName,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector)
Compile an EPL statement. |
static StatementSpecRaw |
EPAdministratorHelper.compilePattern(java.lang.String expression,
java.lang.String expressionForErrorMessage,
boolean addPleaseCheck,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector)
|
static boolean |
StatementContextFactoryUtil.determineHasTableAccess(java.util.List<ExprSubselectNode> subselectNodes,
StatementSpecRaw statementSpecRaw,
EPServicesContext engineServices)
|
static StatementContextEngineServices |
StatementContextFactoryDefault.getStmtCtxEngineServices(EPServicesContext services)
|
void |
ExtensionServicesContext.init(EPServicesContext engine,
EPRuntimeSPI runtimeSPI,
EPAdministratorSPI adminSPI)
Invoked to initialize extension services after engine services initialization. |
StatementContext |
StatementContextFactoryDefault.makeContext(java.lang.String statementId,
java.lang.String statementName,
java.lang.String expression,
StatementType statementType,
EPServicesContext engineServices,
java.util.Map<java.lang.String,java.lang.Object> optAdditionalContext,
boolean isFireAndForget,
java.lang.annotation.Annotation[] annotations,
EPIsolationUnitServices isolationUnitServices,
boolean stateless,
StatementSpecRaw statementSpecRaw,
java.util.List<ExprSubselectNode> subselectNodes,
boolean writesToTables,
java.lang.Object statementUserObject)
|
StatementContext |
StatementContextFactory.makeContext(java.lang.String statementId,
java.lang.String statementName,
java.lang.String expression,
StatementType statementType,
EPServicesContext engineServices,
java.util.Map<java.lang.String,java.lang.Object> optAdditionalContext,
boolean isFireAndForget,
java.lang.annotation.Annotation[] annotations,
EPIsolationUnitServices isolationUnitServices,
boolean stateless,
StatementSpecRaw statementSpecRaw,
java.util.List<ExprSubselectNode> subselectNodes,
boolean writesToTables,
java.lang.Object statementUserObject)
Create a new statement context consisting of statement-level services. |
static void |
EPRuntimeImpl.processStatementScheduleMultiple(EPStatementAgentInstanceHandle handle,
java.lang.Object callbackObject,
EPServicesContext services)
Processing multiple schedule matches for a statement. |
static void |
EPRuntimeImpl.processStatementScheduleSingle(EPStatementHandleCallback handle,
EPServicesContext services)
Processing single schedule matche for a statement. |
void |
StatementIsolationServiceImpl.setEpServicesContext(EPServicesContext epServicesContext)
Set the engine service context. |
void |
StatementContextFactoryDefault.setStmtEngineServices(EPServicesContext services)
|
void |
StatementContextFactory.setStmtEngineServices(EPServicesContext services)
|
Constructors in com.espertech.esper.core.service with parameters of type EPServicesContext | |
---|---|
EPAdministratorContext(EPRuntimeSPI runtimeSPI,
EPServicesContext services,
ConfigurationOperations configurationOperations,
SelectClauseStreamSelectorEnum defaultStreamSelector)
Ctor. |
|
EPAdministratorIsolatedImpl(java.lang.String isolatedServiceName,
EPIsolationUnitServices services,
EPServicesContext unisolatedServices,
EPRuntimeIsolatedImpl isolatedRuntime)
Ctor. |
|
EPContextPartitionAdminImpl(EPServicesContext services)
|
|
EPRuntimeImpl(EPServicesContext services)
Constructor. |
|
EPRuntimeIsolatedImpl(EPIsolationUnitServices svc,
EPServicesContext unisolatedSvc)
Ctor. |
|
EPServiceProviderIsolatedImpl(java.lang.String name,
EPIsolationUnitServices isolatedServices,
EPServicesContext unisolatedSvc,
java.util.Map<java.lang.String,EPServiceProviderIsolatedImpl> providers)
Ctor. |
|
StatementLifecycleSvcImpl(EPServiceProvider epServiceProvider,
EPServicesContext services)
Ctor. |
Uses of EPServicesContext in com.espertech.esper.core.start |
---|
Fields in com.espertech.esper.core.start declared as EPServicesContext | |
---|---|
protected EPServicesContext |
EPPreparedExecuteIUDSingleStream.services
|
Methods in com.espertech.esper.core.start that return EPServicesContext | |
---|---|
EPServicesContext |
EPPreparedExecuteMethodQuery.getServices()
|
EPServicesContext |
EPPreparedExecuteIUDSingleStreamExecUpdate.getServices()
|
EPServicesContext |
EPPreparedExecuteIUDSingleStreamExecInsert.getServices()
|
EPServicesContext |
EPPreparedExecuteIUDSingleStreamExecDelete.getServices()
|
Methods in com.espertech.esper.core.start with parameters of type EPServicesContext | |
---|---|
static void |
EPPreparedExecuteTableHelper.assignTableAccessStrategies(EPServicesContext services,
ExprTableAccessNode[] optionalTableNodes,
AgentInstanceContext agentInstanceContext)
|
static java.util.Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> |
EPStatementStartMethodHelperTableAccess.attachTableAccess(EPServicesContext services,
AgentInstanceContext agentInstanceContext,
ExprTableAccessNode[] tableNodes)
|
protected static SubSelectActivationCollection |
EPStatementStartMethodHelperSubselect.createSubSelectActivation(EPServicesContext services,
StatementSpecCompiled statementSpecContainer,
StatementContext statementContext,
EPStatementDestroyCallbackList destroyCallbacks)
|
protected boolean |
EPStatementStartMethodBase.isQueryPlanLogging(EPServicesContext services)
|
protected static SubSelectStrategyCollection |
EPStatementStartMethodHelperSubselect.planSubSelect(EPServicesContext services,
StatementContext statementContext,
boolean queryPlanLogging,
SubSelectActivationCollection subSelectStreamDesc,
java.lang.String[] outerStreamNames,
EventType[] outerEventTypesSelect,
java.lang.String[] outerEventTypeNamees,
ExprDeclaredNode[] declaredExpressions,
ContextPropertyRegistry contextPropertyRegistry)
|
static EPStatementStartMethodSelectDesc |
EPStatementStartMethodSelectUtil.prepare(StatementSpecCompiled statementSpec,
EPServicesContext services,
StatementContext statementContext,
boolean recoveringResilient,
AgentInstanceContext defaultAgentInstanceContext,
boolean queryPlanLogging,
ViewableActivatorFactory optionalViewableActivatorFactory,
OutputProcessViewCallback optionalOutputProcessViewCallback,
SelectExprProcessorDeliveryCallback selectExprProcessorDeliveryCallback)
|
EPStatementStartResult |
EPStatementStartMethodBase.start(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethod.start(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
Starts the EPL statement. |
EPStatementStartResult |
EPStatementStartMethodUpdate.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodSelect.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodOnTrigger.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateWindow.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateVariable.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateTable.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateSchema.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateIndex.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateGraph.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateExpression.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
EPStatementStartResult |
EPStatementStartMethodCreateContext.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
abstract EPStatementStartResult |
EPStatementStartMethodBase.startInternal(EPServicesContext services,
StatementContext statementContext,
boolean isNewStatement,
boolean isRecoveringStatement,
boolean isRecoveringResilient)
|
static java.util.Map<ExprSubselectNode,SubSelectStrategyHolder> |
EPStatementStartMethodHelperSubselect.startSubselects(EPServicesContext services,
SubSelectStrategyCollection subSelectStrategyCollection,
AgentInstanceContext agentInstanceContext,
java.util.List<StopCallback> stopCallbackList)
|
static FireAndForgetProcessor |
FireAndForgetProcessorFactory.validateResolveProcessor(StreamSpecCompiled streamSpec,
EPServicesContext services)
|
Uses of EPServicesContext in com.espertech.esper.core.thread |
---|
Methods in com.espertech.esper.core.thread with parameters of type EPServicesContext | |
---|---|
void |
ThreadingServiceImpl.initThreading(EPServicesContext services,
EPRuntimeImpl runtime)
|
void |
ThreadingService.initThreading(EPServicesContext services,
EPRuntimeImpl runtime)
Initialize thread pools. |
Constructors in com.espertech.esper.core.thread with parameters of type EPServicesContext | |
---|---|
InboundUnitSendDOM(org.w3c.dom.Node theEvent,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor. |
|
InboundUnitSendMap(java.util.Map map,
java.lang.String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor. |
|
InboundUnitSendObjectArray(java.lang.Object[] properties,
java.lang.String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor. |
|
TimerUnitMultiple(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementAgentInstanceHandle handle,
java.lang.Object callbackObject)
Ctor. |
|
TimerUnitSingle(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementHandleCallback handleCallback)
Ctor. |
Uses of EPServicesContext in com.espertech.esper.dataflow.core |
---|
Methods in com.espertech.esper.dataflow.core that return EPServicesContext | |
---|---|
EPServicesContext |
DataFlowStmtDesc.getServicesContext()
|
Methods in com.espertech.esper.dataflow.core with parameters of type EPServicesContext | |
---|---|
void |
DataFlowServiceImpl.addStartGraph(CreateDataFlowDesc desc,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
boolean newStatement)
|
void |
DataFlowService.addStartGraph(CreateDataFlowDesc desc,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
boolean newStatement)
|
static DataflowStartDesc |
RealizationFactoryInterface.realize(java.lang.String dataFlowName,
java.util.Map<java.lang.Integer,java.lang.Object> operators,
java.util.Map<java.lang.Integer,OperatorMetadataDescriptor> operatorMetadata,
java.util.Set<java.lang.Integer> operatorBuildOrder,
java.util.List<LogicalChannelBinding> bindings,
DataFlowSignalManager dataFlowSignalManager,
EPDataFlowInstantiationOptions options,
EPServicesContext services,
StatementContext statementContext)
|
Constructors in com.espertech.esper.dataflow.core with parameters of type EPServicesContext | |
---|---|
DataFlowStmtDesc(CreateDataFlowDesc graphDesc,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
java.util.Map<GraphOperatorSpec,java.lang.annotation.Annotation[]> operatorAnnotations)
|
Uses of EPServicesContext in com.espertech.esper.dataflow.interfaces |
---|
Methods in com.espertech.esper.dataflow.interfaces that return EPServicesContext | |
---|---|
EPServicesContext |
DataFlowOpInitializateContext.getServicesContext()
|
Constructors in com.espertech.esper.dataflow.interfaces with parameters of type EPServicesContext | |
---|---|
DataFlowOpInitializateContext(java.lang.String dataflowName,
java.lang.String dataflowInstanceId,
java.lang.Object dataflowInstanceUserObject,
java.util.Map<java.lang.Integer,DataFlowOpInputPort> inputPorts,
java.util.Map<java.lang.Integer,DataFlowOpOutputPort> outputPorts,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
EPRuntimeEventSender runtimeEventSender,
EPServiceProvider engine,
java.lang.annotation.Annotation[] operatorAnnotations)
|
Uses of EPServicesContext in com.espertech.esper.epl.metric |
---|
Methods in com.espertech.esper.epl.metric that return EPServicesContext | |
---|---|
EPServicesContext |
MetricExecutionContext.getServices()
Returns services. |
Methods in com.espertech.esper.epl.metric with parameters of type EPServicesContext | |
---|---|
void |
MetricReportingServiceImpl.setContext(EPRuntime runtime,
EPServicesContext servicesContext)
|
void |
MetricReportingService.setContext(EPRuntime runtime,
EPServicesContext servicesContext)
Sets runtime and services. |
Constructors in com.espertech.esper.epl.metric with parameters of type EPServicesContext | |
---|---|
MetricExecutionContext(EPServicesContext epServicesContext,
EPRuntime runtime,
StatementMetricRepository statementMetricRepository)
Ctor. |
|
© 2006-2015 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV NEXT | FRAMES NO FRAMES |