|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.core.EPEQLStmtStartMethod
public class EPEQLStmtStartMethod
Starts and provides the stop method for EQL statements.
Constructor Summary | |
---|---|
EPEQLStmtStartMethod(InsertIntoDesc insertIntoDesc,
java.util.List<SelectExprElement> selectionList,
java.util.List<StreamSpec> streams,
java.util.List<OuterJoinDesc> outerJoinDescList,
ExprNode optionalFilterNode,
java.util.List<ExprNode> groupByNodes,
ExprNode optionalHavingNode,
OutputLimitSpec optionalOutputLimitViewSpecs,
java.util.List<Pair<ExprNode,java.lang.Boolean>> orderByNodes,
java.lang.String eqlStatement,
EPServicesContext services)
Ctor. |
Method Summary | |
---|---|
protected static java.lang.String[] |
determineStreamNames(java.util.List<StreamSpec> streams)
Returns a stream name assigned for each stream, generated if none was supplied. |
Pair<Viewable,EPStatementStopMethod> |
start()
Starts the EQL statement. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public EPEQLStmtStartMethod(InsertIntoDesc insertIntoDesc, java.util.List<SelectExprElement> selectionList, java.util.List<StreamSpec> streams, java.util.List<OuterJoinDesc> outerJoinDescList, ExprNode optionalFilterNode, java.util.List<ExprNode> groupByNodes, ExprNode optionalHavingNode, OutputLimitSpec optionalOutputLimitViewSpecs, java.util.List<Pair<ExprNode,java.lang.Boolean>> orderByNodes, java.lang.String eqlStatement, EPServicesContext services)
insertIntoDesc
- describes the insert-into information supplied, or null if no insert into definedselectionList
- describes the list of selected fields, empty list if wildcarded (SELECT-clause)streams
- is a definition of the event streams (FROM-clause)outerJoinDescList
- is a list of outer join descriptors indicating join type and properties (OUTER-JOIN clauses)optionalFilterNode
- is filter conditions that result sets must meet (WHERE clause)groupByNodes
- is a list of expressions that represent the grouping criteria in a group by clause,
empty list if none supplied (GROUP BY)optionalHavingNode
- is filter conditions that grouped-by results must meet (HAVING clause)optionalOutputLimitViewSpecs
- is a list of the output rate limiting views,
empty list if none supplied (OUTPUT clause)orderByNodes
- is the order-by expression nodeseqlStatement
- is the expression textservices
- is the service instances for dependency injectionMethod Detail |
---|
public Pair<Viewable,EPStatementStopMethod> start() throws ExprValidationException, ViewProcessingException
ExprValidationException
- when the expression validation fails
ViewProcessingException
- when views cannot be startedprotected static java.lang.String[] determineStreamNames(java.util.List<StreamSpec> streams)
streams
- - stream specifications
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |