| Package | Description |
|---|---|
| com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
| 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.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
| Modifier and Type | Method and Description |
|---|---|
SelectClauseStreamSelectorEnum |
EPAdministratorContext.getDefaultStreamSelector()
Returns the default stream selector.
|
| 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) |
static StatementSpecRaw |
EPAdministratorHelper.compilePattern(String expression,
String expressionForErrorMessage,
boolean addPleaseCheck,
EPServicesContext services,
SelectClauseStreamSelectorEnum defaultStreamSelector) |
| Constructor and Description |
|---|
EPAdministratorContext(EPRuntimeSPI runtimeSPI,
EPServicesContext services,
ConfigurationOperations configurationOperations,
SelectClauseStreamSelectorEnum defaultStreamSelector)
Ctor.
|
| Constructor and Description |
|---|
EPLTreeWalkerListener(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EngineImportService engineImportService,
VariableService variableService,
SchedulingService schedulingService,
SelectClauseStreamSelectorEnum defaultStreamSelector,
String engineURI,
ConfigurationInformation configurationInformation,
PatternNodeFactory patternNodeFactory,
ContextManagementService contextManagementService,
List<String> scriptBodies,
ExprDeclaredService exprDeclaredService,
TableService tableService) |
| Modifier and Type | Method and Description |
|---|---|
SelectClauseStreamSelectorEnum |
StatementSpecRaw.getSelectStreamSelectorEnum()
Returns the stream selector (rstream/istream).
|
SelectClauseStreamSelectorEnum |
StatementSpecCompiled.getSelectStreamSelectorEnum()
Returns the stream selector (rstream/istream).
|
SelectClauseStreamSelectorEnum |
InsertIntoDesc.getStreamSelector()
Returns the stream(s) selected for inserting into.
|
static SelectClauseStreamSelectorEnum |
SelectClauseStreamSelectorEnum.mapFromSODA(StreamSelector selector)
Maps the SODA-selector to the internal representation
|
static SelectClauseStreamSelectorEnum |
SelectClauseStreamSelectorEnum.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static SelectClauseStreamSelectorEnum[] |
SelectClauseStreamSelectorEnum.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
static StreamSelector |
SelectClauseStreamSelectorEnum.mapFromSODA(SelectClauseStreamSelectorEnum selector)
Maps the internal stream selector to the SODA-representation
|
void |
StatementSpecRaw.setSelectStreamDirEnum(SelectClauseStreamSelectorEnum selectStreamDirEnum)
Sets the stream selector (rstream/istream/both etc).
|
void |
StatementSpecCompiled.setSelectStreamDirEnum(SelectClauseStreamSelectorEnum selectStreamDirEnum)
Sets the stream selection.
|
| Constructor and Description |
|---|
InsertIntoDesc(SelectClauseStreamSelectorEnum streamSelector,
String eventTypeName)
Ctor.
|
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) |
StatementSpecRaw(SelectClauseStreamSelectorEnum defaultStreamSelector)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
SelectClauseStreamSelectorEnum |
OutputStrategyPostProcessFactory.getInsertIntoStreamSelector() |
SelectClauseStreamSelectorEnum |
OutputProcessViewConditionFactory.getSelectClauseStreamSelectorEnum() |
SelectClauseStreamSelectorEnum |
OutputStrategyPostProcessFactory.getSelectStreamDirEnum() |
| Constructor and Description |
|---|
OutputProcessViewConditionFactory(StatementContext statementContext,
OutputStrategyPostProcessFactory postProcessFactory,
boolean distinct,
ExprTimePeriod afterTimePeriod,
Integer afterConditionNumberOfEvents,
EventType resultEventType,
OutputConditionFactory outputConditionFactory,
int streamCount,
OutputProcessViewConditionFactory.ConditionType conditionType,
OutputLimitLimitType outputLimitLimitType,
boolean terminable,
boolean hasAfter,
boolean isUnaggregatedUngrouped,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
OutputStrategyPostProcessFactory(boolean route,
SelectClauseStreamSelectorEnum insertIntoStreamSelector,
SelectClauseStreamSelectorEnum selectStreamDirEnum,
InternalEventRouter internalEventRouter,
EPStatementHandle epStatementHandle,
boolean addToFront,
TableService tableService,
String tableName) |