Package | Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
ViewableActivatorFilterProxy.getServices() |
Modifier and Type | Method and Description |
---|---|
ViewableActivator |
ViewableActivatorFactoryDefault.createFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
Annotation[] annotations,
boolean subselect,
InstrumentationAgent instrumentationAgentSubquery,
boolean isCanIterate,
Integer streamNumFromClause) |
ViewableActivator |
ViewableActivatorFactory.createFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
Annotation[] annotations,
boolean subselect,
InstrumentationAgent instrumentationAgentSubquery,
boolean isCanIterate,
Integer streamNumFromClause) |
ViewableActivator |
ViewableActivatorFactoryDefault.createStreamReuseView(EPServicesContext services,
StatementContext statementContext,
StatementSpecCompiled statementSpec,
FilterStreamSpecCompiled filterStreamSpec,
boolean isJoin,
ExprEvaluatorContextStatement evaluatorContextStmt,
boolean filterSubselectSameStream,
int streamNum,
boolean isCanIterateUnbound) |
ViewableActivator |
ViewableActivatorFactory.createStreamReuseView(EPServicesContext services,
StatementContext statementContext,
StatementSpecCompiled statementSpec,
FilterStreamSpecCompiled filterStreamSpec,
boolean isJoin,
ExprEvaluatorContextStatement evaluatorContextStmt,
boolean filterSubselectSameStream,
int streamNum,
boolean isCanIterateUnbound) |
Constructor and Description |
---|
ViewableActivatorFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
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) |
Modifier and Type | Field and Description |
---|---|
protected EPServicesContext |
StatementAgentInstanceFactorySelect.services |
protected EPServicesContext |
StatementAgentInstanceFactoryOnTriggerBase.services |
protected EPServicesContext |
StatementAgentInstanceFactoryCreateWindow.services |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
StatementAgentInstanceFactorySelect.getServices() |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
ContextControllerFactoryServiceContext.getServicesContext() |
EPServicesContext |
ContextControllerFactoryContext.getServicesContext() |
Modifier and Type | Method and Description |
---|---|
void |
ContextManagementServiceImpl.addContextSpec(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
CreateContextDesc contextDesc,
boolean isRecoveringResilient,
EventType statementResultEventType) |
void |
ContextManagementService.addContextSpec(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
CreateContextDesc contextDesc,
boolean isRecoveringResilient,
EventType statementResultEventType) |
static ContextControllerCondition |
ContextControllerConditionFactory.getEndpoint(String contextName,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
ContextDetailCondition endpoint,
ContextControllerConditionCallback callback,
ContextInternalFilterAddendum filterAddendum,
boolean isStartEndpoint,
int nestingLevel,
int pathId,
int subpathId) |
Modifier and Type | Method and Description |
---|---|
SubSelectStrategyRealization |
SubSelectStrategyFactoryLocalViewPreloaded.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
SubSelectStrategyRealization |
SubSelectStrategyFactoryIndexShare.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
SubSelectStrategyRealization |
SubSelectStrategyFactory.instantiate(EPServicesContext services,
Viewable viewableRoot,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
int subqueryNumber,
boolean isRecoveringResilient) |
Modifier and Type | Method and Description |
---|---|
static void |
StatementAgentInstanceUtil.evaluateEventForStatement(EPServicesContext servicesContext,
EventBean theEvent,
Map<String,Object> optionalTriggeringPattern,
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,
Map<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,
boolean removedStatementResources) |
static void |
StatementAgentInstanceUtil.stopAgentInstanceRemoveResources(AgentInstance agentInstance,
Map<String,Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired) |
static void |
StatementAgentInstanceUtil.stopAgentInstances(List<AgentInstance> agentInstances,
Map<String,Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop,
boolean leaveLocksAcquired) |
Modifier and Type | Field and Description |
---|---|
protected EPServicesContext |
StatementLifecycleSvcImpl.services
Services context for statement lifecycle management.
|
protected EPServicesContext |
EPRuntimeImpl.services |
protected EPServicesContext |
EPRuntimeIsolatedImpl.unisolatedServices |
Modifier and Type | Method and Description |
---|---|
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() |
Modifier and Type | Method and Description |
---|---|
protected static StatementSpecCompiled |
StatementLifecycleSvcImpl.compile(StatementSpecRaw spec,
String eplStatement,
StatementContext statementContext,
boolean isSubquery,
boolean isOnDemandQuery,
Annotation[] annotations,
List<ExprSubselectNode> subselectNodes,
List<ExprDeclaredNode> declaredNodes,
Set<ExprTableAccessNode> tableAccessNodes,
EPServicesContext servicesContext)
Compiles a statement returning the compile (verified, non-serializable) form of a statement.
|
static StatementSpecRaw |
EPAdministratorHelper.compileEPL(String eplStatement,
String eplStatementForErrorMsg,
boolean addPleaseCheck,
String statementName,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector)
Compile an EPL statement.
|
static StatementSpecRaw |
EPAdministratorHelper.compilePattern(String expression,
String expressionForErrorMessage,
boolean addPleaseCheck,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector) |
static boolean |
StatementContextFactoryUtil.determineHasTableAccess(List<ExprSubselectNode> subselectNodes,
StatementSpecRaw statementSpecRaw,
EPServicesContext engineServices) |
static StatementContextEngineServices |
StatementContextFactoryDefault.getStmtCtxEngineServices(EPServicesContext services) |
void |
EngineLevelExtensionServicesContext.init(EPServicesContext engine,
EPRuntimeSPI runtimeSPI,
EPAdministratorSPI adminSPI)
Invoked to initialize extension services after engine services initialization.
|
EPRuntimeIsolatedSPI |
EPRuntimeIsolatedFactoryImpl.make(EPIsolationUnitServices isolatedServices,
EPServicesContext unisolatedSvc) |
EPRuntimeIsolatedSPI |
EPRuntimeIsolatedFactory.make(EPIsolationUnitServices isolatedServices,
EPServicesContext unisolatedSvc) |
StatementContext |
StatementContextFactoryDefault.makeContext(int statementId,
String statementName,
String expression,
StatementType statementType,
EPServicesContext engineServices,
Map<String,Object> optAdditionalContext,
boolean isFireAndForget,
Annotation[] annotations,
EPIsolationUnitServices isolationUnitServices,
boolean stateless,
StatementSpecRaw statementSpecRaw,
List<ExprSubselectNode> subselectNodes,
boolean writesToTables,
Object statementUserObject) |
StatementContext |
StatementContextFactory.makeContext(int statementId,
String statementName,
String expression,
StatementType statementType,
EPServicesContext engineServices,
Map<String,Object> optAdditionalContext,
boolean isFireAndForget,
Annotation[] annotations,
EPIsolationUnitServices isolationUnitServices,
boolean stateless,
StatementSpecRaw statementSpecRaw,
List<ExprSubselectNode> subselectNodes,
boolean writesToTables,
Object statementUserObject) |
static void |
EPRuntimeImpl.processStatementScheduleMultiple(EPStatementAgentInstanceHandle handle,
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) |
Constructor and Description |
---|
EPAdministratorContext(EPRuntimeSPI runtimeSPI,
EPServicesContext services,
ConfigurationOperations configurationOperations,
SelectClauseStreamSelectorEnum defaultStreamSelector)
Ctor.
|
EPAdministratorIsolatedImpl(String isolatedServiceName,
EPIsolationUnitServices services,
EPServicesContext unisolatedServices,
EPRuntimeIsolatedSPI isolatedRuntime)
Ctor.
|
EPContextPartitionAdminImpl(EPServicesContext services) |
EPRuntimeImpl(EPServicesContext services)
Constructor.
|
EPRuntimeIsolatedImpl(EPIsolationUnitServices svc,
EPServicesContext unisolatedSvc)
Ctor.
|
EPServiceProviderIsolatedImpl(String name,
EPIsolationUnitServices isolatedServices,
EPServicesContext unisolatedSvc,
Map<String,EPServiceProviderIsolatedImpl> providers)
Ctor.
|
StatementLifecycleSvcImpl(EPServiceProvider epServiceProvider,
EPServicesContext services)
Ctor.
|
Modifier and Type | Field and Description |
---|---|
protected EPServicesContext |
EPPreparedExecuteIUDSingleStream.services |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
EPPreparedExecuteMethodQuery.getServices() |
EPServicesContext |
EPPreparedExecuteIUDSingleStreamExecUpdate.getServices() |
EPServicesContext |
EPPreparedExecuteIUDSingleStreamExecInsert.getServices() |
EPServicesContext |
EPPreparedExecuteIUDSingleStreamExecDelete.getServices() |
Modifier and Type | Method and Description |
---|---|
static void |
EPPreparedExecuteTableHelper.assignTableAccessStrategies(EPServicesContext services,
ExprTableAccessNode[] optionalTableNodes,
AgentInstanceContext agentInstanceContext) |
static 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,
String[] outerStreamNames,
EventType[] outerEventTypesSelect,
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 Map<ExprSubselectNode,SubSelectStrategyHolder> |
EPStatementStartMethodHelperSubselect.startSubselects(EPServicesContext services,
SubSelectStrategyCollection subSelectStrategyCollection,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
boolean isRecoveringResilient) |
static FireAndForgetProcessor |
FireAndForgetProcessorFactory.validateResolveProcessor(StreamSpecCompiled streamSpec,
EPServicesContext services) |
Modifier and Type | Method and Description |
---|---|
void |
ThreadingServiceImpl.initThreading(EPServicesContext services,
EPRuntimeImpl runtime) |
void |
ThreadingService.initThreading(EPServicesContext services,
EPRuntimeImpl runtime)
Initialize thread pools.
|
Constructor and Description |
---|
InboundUnitSendAvro(Object genericRecordDotData,
String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendDOM(Node theEvent,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendMap(Map map,
String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
InboundUnitSendObjectArray(Object[] properties,
String eventTypeName,
EPServicesContext services,
EPRuntimeImpl runtime)
Ctor.
|
TimerUnitMultiple(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementAgentInstanceHandle handle,
Object callbackObject)
Ctor.
|
TimerUnitSingle(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementHandleCallback handleCallback)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
DataFlowStmtDesc.getServicesContext() |
Modifier and Type | Method and Description |
---|---|
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(String dataFlowName,
Map<Integer,Object> operators,
Map<Integer,OperatorMetadataDescriptor> operatorMetadata,
Set<Integer> operatorBuildOrder,
List<LogicalChannelBinding> bindings,
DataFlowSignalManager dataFlowSignalManager,
EPDataFlowInstantiationOptions options,
EPServicesContext services,
StatementContext statementContext) |
Constructor and Description |
---|
DataFlowStmtDesc(CreateDataFlowDesc graphDesc,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
Map<GraphOperatorSpec,Annotation[]> operatorAnnotations) |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
DataFlowOpInitializateContext.getServicesContext() |
Constructor and Description |
---|
DataFlowOpInitializateContext(String dataflowName,
String dataflowInstanceId,
Object dataflowInstanceUserObject,
Map<Integer,DataFlowOpInputPort> inputPorts,
Map<Integer,DataFlowOpOutputPort> outputPorts,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
EPRuntimeEventSender runtimeEventSender,
EPServiceProvider engine,
Annotation[] operatorAnnotations) |
Modifier and Type | Method and Description |
---|---|
EPServicesContext |
MetricExecutionContext.getServices()
Returns services.
|
Modifier and Type | Method and Description |
---|---|
void |
MetricReportingServiceImpl.setContext(EPRuntime runtime,
EPServicesContext servicesContext) |
void |
MetricReportingService.setContext(EPRuntime runtime,
EPServicesContext servicesContext)
Sets runtime and services.
|
Constructor and Description |
---|
MetricExecutionContext(EPServicesContext epServicesContext,
EPRuntime runtime,
StatementMetricRepository statementMetricRepository)
Ctor.
|