Package | Description |
---|---|
com.espertech.esper.dataflow.core |
Data flow core classes.
|
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.
|
Modifier and Type | Method and Description |
---|---|
CreateDataFlowDesc |
DataFlowStmtDesc.getGraphDesc() |
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) |
Constructor and Description |
---|
DataFlowStmtDesc(CreateDataFlowDesc graphDesc,
StatementContext statementContext,
EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContext,
Map<GraphOperatorSpec,Annotation[]> operatorAnnotations) |
Modifier and Type | Method and Description |
---|---|
static CreateDataFlowDesc |
ASTGraphHelper.walkCreateDataFlow(EsperEPL2GrammarParser.CreateDataflowContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,Object> astGraphNodeMap,
EngineImportService engineImportService) |
Modifier and Type | Method and Description |
---|---|
CreateDataFlowDesc |
StatementSpecRaw.getCreateDataFlowDesc() |
CreateDataFlowDesc |
StatementSpecCompiled.getCreateGraphDesc() |
Modifier and Type | Method and Description |
---|---|
void |
StatementSpecRaw.setCreateDataFlowDesc(CreateDataFlowDesc createDataFlowDesc) |
Constructor and Description |
---|
StatementSpecCompiled(OnTriggerDesc onTriggerDesc,
CreateWindowDesc createWindowDesc,
CreateIndexDesc createIndexDesc,
CreateVariableDesc createVariableDesc,
CreateTableDesc createTableDesc,
CreateSchemaDesc createSchemaDesc,
InsertIntoDesc insertIntoDesc,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
SelectClauseSpecCompiled selectClauseSpec,
StreamSpecCompiled[] streamSpecs,
OuterJoinDesc[] outerJoinDescList,
ExprNode filterExprRootNode,
ExprNode havingExprRootNode,
OutputLimitSpec outputLimitSpec,
OrderByItem[] orderByList,
ExprSubselectNode[] subSelectExpressions,
ExprDeclaredNode[] declaredExpressions,
ExpressionScriptProvided[] scripts,
Set<String> variableReferences,
RowLimitSpec rowLimitSpec,
String[] eventTypeReferences,
Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
Map<Integer,List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |