Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
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
|
Modifier and Type | Method and Description |
---|---|
static StatementSpecRaw |
EPAdministratorHelper.compileEPL(String eplStatement,
String eplStatementForErrorMsg,
boolean addPleaseCheck,
String statementName,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector)
Compile an EPL statement.
|
static StatementSpecRaw |
EPAdministratorHelper.compileEPL(String eplStatement,
String eplStatementForErrorMsg,
boolean addPleaseCheck,
String statementName,
SelectClauseStreamSelectorEnum defaultStreamSelector,
EngineImportService engineImportService,
VariableService variableService,
SchedulingService schedulingService,
String engineURI,
ConfigurationInformation configSnapshot,
PatternNodeFactory patternNodeFactory,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
TableService tableService) |
StatementSpecRaw |
EPAdministratorSPI.compileEPLToRaw(String epl) |
StatementSpecRaw |
EPAdministratorImpl.compileEPLToRaw(String epl) |
static StatementSpecRaw |
EPAdministratorHelper.compilePattern(String expression,
String expressionForErrorMessage,
boolean addPleaseCheck,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector) |
StatementSpecRaw |
StatementMetadataFactoryContext.getStatementSpec() |
StatementSpecRaw |
EPAdministratorSPI.mapSODAToRaw(EPStatementObjectModel model) |
StatementSpecRaw |
EPAdministratorImpl.mapSODAToRaw(EPStatementObjectModel model) |
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.
|
EPStatement |
StatementLifecycleSvcImpl.createAndStart(StatementSpecRaw statementSpec,
String expression,
boolean isPattern,
String optStatementName,
Object userObject,
EPIsolationUnitServices isolationUnitServices,
Integer optionalStatementId,
EPStatementObjectModel optionalModel) |
EPStatement |
StatementLifecycleSvc.createAndStart(StatementSpecRaw statementSpec,
String expression,
boolean isPattern,
String optStatementName,
Object userObject,
EPIsolationUnitServices isolationUnitServices,
Integer optionalStatementId,
EPStatementObjectModel optionalModel)
Create and start the statement.
|
protected StatementLifecycleSvcImpl.EPStatementDesc |
StatementLifecycleSvcImpl.createStopped(StatementSpecRaw statementSpec,
Annotation[] annotations,
String expression,
boolean isPattern,
String statementName,
boolean nameProvided,
int statementId,
Map<String,Object> optAdditionalContext,
Object statementUserObject,
EPIsolationUnitServices isolationUnitServices,
boolean isFailed,
EPStatementObjectModel optionalModel)
Create stopped statement.
|
protected StatementLifecycleSvcImpl.EPStatementDesc |
StatementLifecycleSvcImpl.createStoppedAssignName(StatementSpecRaw statementSpec,
String expression,
boolean isPattern,
String optStatementName,
int statementId,
Map<String,Object> optAdditionalContext,
Object userObject,
EPIsolationUnitServices isolationUnitServices,
EPStatementObjectModel optionalModel)
Creates and starts statement.
|
static boolean |
StatementContextFactoryUtil.determineHasTableAccess(List<ExprSubselectNode> subselectNodes,
StatementSpecRaw statementSpecRaw,
EPServicesContext engineServices) |
static StatementType |
StatementMetadataFactoryDefault.getStatementType(StatementSpecRaw statementSpec,
boolean pattern) |
static boolean |
StatementLifecycleSvcUtil.isWritesToTables(StatementSpecRaw statementSpec,
TableService tableService) |
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) |
EPStatementObjectModel |
EPAdministratorSPI.mapRawToSODA(StatementSpecRaw raw) |
EPStatementObjectModel |
EPAdministratorImpl.mapRawToSODA(StatementSpecRaw raw) |
static void |
StatementLifecycleSvcUtil.walkStatement(StatementSpecRaw spec,
ExprNodeSubselectDeclaredDotVisitor visitor) |
static void |
StatementLifecycleSvcUtil.walkStreamSpecs(StatementSpecRaw spec,
ExprNodeSubselectDeclaredDotVisitor visitor) |
Constructor and Description |
---|
StatementMetadataFactoryContext(String statementName,
int statementId,
StatementContext statementContext,
StatementSpecRaw statementSpec,
String expression,
boolean pattern,
EPStatementObjectModel optionalModel) |
Modifier and Type | Method and Description |
---|---|
StatementSpecRaw |
ExprSubselectNode.getStatementSpecRaw()
Returns the uncompiled statement spec.
|
Constructor and Description |
---|
ExprSubselectAllSomeAnyNode(StatementSpecRaw statementSpec,
boolean not,
boolean all,
RelationalOpEnum relationalOpEnum)
Ctor.
|
ExprSubselectExistsNode(StatementSpecRaw statementSpec)
Ctor.
|
ExprSubselectInNode(StatementSpecRaw statementSpec,
boolean isNotIn) |
ExprSubselectNode(StatementSpecRaw statementSpec)
Ctor.
|
ExprSubselectRowNode(StatementSpecRaw statementSpec)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
StatementSpecRaw |
EPLTreeWalkerListener.getStatementSpec() |
Modifier and Type | Method and Description |
---|---|
static void |
ASTExprHelper.addOptionalSimpleProperty(ExprNode exprNode,
org.antlr.v4.runtime.Token token,
VariableService variableService,
StatementSpecRaw spec) |
static void |
ASTTableExprHelper.addTableExpressionReference(StatementSpecRaw statementSpec,
ExprTableAccessNode tableNode) |
static void |
ASTTableExprHelper.addTableExpressionReference(StatementSpecRaw statementSpec,
Set<ExprTableAccessNode> tableNodes) |
static void |
ASTExprHelper.addVariableReference(StatementSpecRaw statementSpec,
String variableName) |
static void |
ASTLibFunctionHelper.handleLibFunc(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EsperEPL2GrammarParser.LibFunctionContext ctx,
ConfigurationInformation configurationInformation,
EngineImportService engineImportService,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
String engineURI,
ExpressionDeclDesc expressionDeclarations,
ExprDeclaredService exprDeclaredService,
List<ExpressionScriptProvided> scriptExpressions,
ContextDescriptor contextDescriptor,
TableService tableService,
StatementSpecRaw statementSpec,
VariableService variableService) |
static ExprNode |
ASTExprHelper.resolvePropertyOrVariableIdentifier(String identifier,
VariableService variableService,
StatementSpecRaw spec) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprAllParams(EsperEPL2GrammarParser.TimePeriodContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
StatementSpecRaw spec,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
static StatementSpecRaw |
StatementSpecMapper.map(EPStatementObjectModel sodaStatement,
EngineImportService engineImportService,
VariableService variableService,
ConfigurationInformation configuration,
SchedulingService schedulingService,
String engineURI,
PatternNodeFactory patternNodeFactory,
NamedWindowMgmtService namedWindowMgmtService,
ContextManagementService contextManagementService,
ExprDeclaredService exprDeclaredService,
TableService tableService) |
Modifier and Type | Method and Description |
---|---|
static StatementSpecUnMapResult |
StatementSpecMapper.unmap(StatementSpecRaw statementSpec)
Maps the internal representation of a statement to the SODA object model.
|
Modifier and Type | Method and Description |
---|---|
static List<FilterSpecRaw> |
StatementSpecRawAnalyzer.analyzeFilters(StatementSpecRaw spec) |
static List<ExprNode> |
StatementSpecRawAnalyzer.collectExpressionsShallow(StatementSpecRaw raw) |
static ExprNodeSubselectDeclaredDotVisitor |
StatementSpecRawAnalyzer.walkSubselectAndDeclaredDotExpr(StatementSpecRaw spec) |