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.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.core |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.spec.util |
Statement spec utilities
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
Modifier and Type | Method and Description |
---|---|
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 |
---|
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 StatementSpecCompiled |
StatementAgentInstanceFactorySelect.statementSpec |
protected StatementSpecCompiled |
StatementAgentInstanceFactoryOnTriggerBase.statementSpec |
protected StatementSpecCompiled |
StatementAgentInstanceFactoryCreateWindow.statementSpec |
Modifier and Type | Method and Description |
---|---|
StatementSpecCompiled |
StatementAgentInstanceFactorySelect.getStatementSpec() |
Modifier and Type | Method and Description |
---|---|
protected static StatementAgentInstanceFactoryOnTriggerNamedWindow.IndexHintPair |
StatementAgentInstanceFactoryOnTriggerNamedWindow.getIndexHintPair(StatementContext statementContext,
StatementSpecCompiled statementSpec) |
Modifier and Type | Method and Description |
---|---|
StatementSpecCompiled |
ContextControllerStatementBase.getStatementSpec() |
Modifier and Type | Method and Description |
---|---|
static FilterValueSetParam[][] |
ContextControllerPartitionedUtil.getAddendumFilters(Object keyValue,
FilterSpecCompiled filtersSpec,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled) |
static void |
ContextControllerPartitionedUtil.populateAddendumFilters(Object keyValue,
List<FilterSpecCompiled> filtersSpecs,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled,
IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums) |
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.
|
StatementSpecCompiled |
StatementLifecycleSvcImpl.getStatementSpec(int statementId) |
StatementSpecCompiled |
StatementLifecycleSvc.getStatementSpec(int statementId) |
StatementSpecCompiled |
StatementContext.getStatementSpecCompiled() |
Modifier and Type | Method and Description |
---|---|
void |
StatementContext.setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled) |
Modifier and Type | Field and Description |
---|---|
protected StatementSpecCompiled |
EPStatementStartMethodBase.statementSpec |
protected StatementSpecCompiled |
EPPreparedExecuteIUDSingleStream.statementSpec |
Modifier and Type | Method and Description |
---|---|
StatementSpecCompiled |
EPStatementStartMethodBase.getStatementSpec() |
StatementSpecCompiled |
EPStatementStartMethod.getStatementSpec() |
Modifier and Type | Method and Description |
---|---|
protected static SubSelectActivationCollection |
EPStatementStartMethodHelperSubselect.createSubSelectActivation(EPServicesContext services,
StatementSpecCompiled statementSpecContainer,
StatementContext statementContext,
EPStatementDestroyCallbackList destroyCallbacks) |
protected static boolean |
EPStatementStartMethodHelperUtil.determineSubquerySameStream(StatementSpecCompiled statementSpec,
FilterStreamSpecCompiled filterStreamSpec) |
static EPStatementStartMethod |
EPStatementStartMethodFactory.makeStartMethod(StatementSpecCompiled statementSpec)
Ctor.
|
static EPStatementStartMethodSelectDesc |
EPStatementStartMethodSelectUtil.prepare(StatementSpecCompiled statementSpec,
EPServicesContext services,
StatementContext statementContext,
boolean recoveringResilient,
AgentInstanceContext defaultAgentInstanceContext,
boolean queryPlanLogging,
ViewableActivatorFactory optionalViewableActivatorFactory,
OutputProcessViewCallback optionalOutputProcessViewCallback,
SelectExprProcessorDeliveryCallback selectExprProcessorDeliveryCallback) |
protected static void |
EPPreparedExecuteMethodHelper.validateFAFQuery(StatementSpecCompiled statementSpec) |
protected static void |
EPStatementStartMethodHelperValidate.validateNodes(StatementSpecCompiled statementSpec,
StatementContext statementContext,
StreamTypeService typeService,
ViewResourceDelegateUnverified viewResourceDelegate)
Validate filter and join expression nodes.
|
Modifier and Type | Method and Description |
---|---|
static ResultSetProcessorFactoryDesc |
ResultSetProcessorFactoryFactory.getProcessorPrototype(StatementSpecCompiled statementSpec,
StatementContext stmtContext,
StreamTypeService typeService,
ViewResourceDelegateUnverified viewResourceDelegate,
boolean[] isUnidirectionalStream,
boolean allowAggregation,
ContextPropertyRegistry contextPropertyRegistry,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
ConfigurationInformation configurationInformation,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean isFireAndForget,
boolean isOnSelect) |
Modifier and Type | Method and Description |
---|---|
StatementSpecCompiled |
ExprSubselectNode.getStatementSpecCompiled()
Returns the compiled statement spec.
|
Modifier and Type | Method and Description |
---|---|
void |
ExprSubselectNode.setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled,
int subselectNumber)
Supplies a compiled statement spec.
|
Modifier and Type | Field and Description |
---|---|
static StatementSpecCompiled |
StatementSpecCompiled.DEFAULT_SELECT_ALL_EMPTY |
Modifier and Type | Method and Description |
---|---|
static StatementSpecCompiledAnalyzerResult |
StatementSpecCompiledAnalyzer.analyzeFilters(StatementSpecCompiled spec) |
Modifier and Type | Method and Description |
---|---|
static OutputProcessViewFactory |
OutputProcessViewFactoryFactory.make(StatementSpecCompiled statementSpec,
InternalEventRouter internalEventRouter,
StatementContext statementContext,
EventType resultEventType,
OutputProcessViewCallback optionalOutputProcessViewCallback,
TableService tableService,
ResultSetProcessorType resultSetProcessorType,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
StatementVariableRef statementVariableRef) |