Package | Description |
---|---|
com.espertech.esper.core.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
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 |
---|---|
StreamSpecCompiled |
SubSelectActivationHolder.getStreamSpecCompiled() |
Constructor and Description |
---|
SubSelectActivationHolder(int streamNumber,
EventType viewableType,
ViewFactoryChain viewFactoryChain,
ViewableActivator activator,
StreamSpecCompiled streamSpecCompiled) |
Modifier and Type | Method and Description |
---|---|
protected static String[] |
EPStatementStartMethodHelperUtil.determineStreamNames(StreamSpecCompiled[] streams)
Returns a stream name assigned for each stream, generated if none was supplied.
|
static FireAndForgetProcessor |
FireAndForgetProcessorFactory.validateResolveProcessor(StreamSpecCompiled streamSpec,
EPServicesContext services) |
Modifier and Type | Class and Description |
---|---|
class |
DBStatementStreamSpec
Specification object for historical data poll via database SQL statement.
|
class |
FilterStreamSpecCompiled
Specification for building an event stream out of a filter for events (supplying type and basic filter criteria)
and views onto these events which are staggered onto each other to supply a final stream of events.
|
class |
MethodStreamSpec
Specification object for historical data poll via database SQL statement.
|
class |
NamedWindowConsumerStreamSpec
Specification for use of an existing named window.
|
class |
PatternStreamSpecCompiled
Specification for building an event stream out of a pattern statement and views staggered onto the
pattern statement.
|
class |
TableQueryStreamSpec
Specification for use of an existing table.
|
Modifier and Type | Field and Description |
---|---|
static StreamSpecCompiled[] |
StreamSpecCompiled.EMPTY_STREAM_ARRAY |
Modifier and Type | Method and Description |
---|---|
StreamSpecCompiled |
StreamSpecRaw.compile(StatementContext statementContext,
Set<String> eventTypeReferences,
boolean isInsertInto,
Collection<Integer> assignedTypeNumberStack,
boolean isJoin,
boolean isContextDeclaration,
boolean isOnTrigger,
String optionalStreamName)
Compiles a raw stream specification consisting event type information and filter expressions
to an validated, optimized form for use with filter service
|
StreamSpecCompiled |
MethodStreamSpec.compile(StatementContext context,
Set<String> eventTypeReferences,
boolean isInsertInto,
Collection<Integer> assignedTypeNumberStack,
boolean isJoin,
boolean isContextDeclaration,
boolean isOnTrigger,
String optionalStreamName) |
StreamSpecCompiled |
FilterStreamSpecRaw.compile(StatementContext context,
Set<String> eventTypeReferences,
boolean isInsertInto,
Collection<Integer> assignedTypeNumberStack,
boolean isJoin,
boolean isContextDeclaration,
boolean isOnTrigger,
String optionalStreamName) |
StreamSpecCompiled |
DBStatementStreamSpec.compile(StatementContext statementContext,
Set<String> eventTypeReferences,
boolean isInsertInto,
Collection<Integer> assignedTypeNumberStack,
boolean isJoin,
boolean isContextDeclaration,
boolean isOnTrigger,
String optionalStreamName) |
StreamSpecCompiled[] |
StatementSpecCompiled.getStreamSpecs()
Returns the FROM-clause stream definitions.
|
Modifier and Type | Method and Description |
---|---|
void |
StatementSpecCompiled.setStreamSpecs(StreamSpecCompiled[] streamSpecs)
Sets the FROM-clause stream definitions.
|
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) |