| Package | Description |
|---|---|
| com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
| com.espertech.esper.epl.core |
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.db |
Database SQL polling views and caches
|
| com.espertech.esper.epl.join.base |
Join process interfaces and glue code
|
| com.espertech.esper.epl.join.exec.base |
Inner join execution
|
| Modifier and Type | Field and Description |
|---|---|
protected HistoricalEventViewable |
ViewableActivatorHistorical.historicalEventViewable |
| Modifier and Type | Method and Description |
|---|---|
ViewableActivator |
ViewableActivatorFactoryDefault.makeHistorical(HistoricalEventViewable historicalEventViewable) |
ViewableActivator |
ViewableActivatorFactory.makeHistorical(HistoricalEventViewable historicalEventViewable) |
| Constructor and Description |
|---|
ViewableActivatorHistorical(HistoricalEventViewable historicalEventViewable) |
| Modifier and Type | Class and Description |
|---|---|
class |
MethodPollingViewable
Polling-data provider that calls a static method on a class and passed parameters, and wraps the
results as POJO events.
|
| Modifier and Type | Method and Description |
|---|---|
static HistoricalEventViewable |
MethodPollingViewableFactory.createPollMethodView(int streamNumber,
MethodStreamSpec methodStreamSpec,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
EngineImportService engineImportService,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
String contextName,
DataCacheFactory dataCacheFactory,
StatementContext statementContext)
Creates a method-invocation polling view for use as a stream that calls a method, or pulls results from cache.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DatabasePollingViewable
Implements a poller viewable that uses a polling strategy, a cache and
some input parameters extracted from event streams to perform the polling.
|
| Modifier and Type | Method and Description |
|---|---|
static HistoricalEventViewable |
DatabasePollingViewableFactory.createDBStatementView(int statementId,
int streamNumber,
DBStatementStreamSpec databaseStreamSpec,
DatabaseConfigService databaseConfigService,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
SQLColumnTypeConversion columnTypeConversionHook,
SQLOutputRowConversion outputRowConversionHook,
boolean enableJDBCLogging,
DataCacheFactory dataCacheFactory,
StatementContext statementContext)
Creates the viewable for polling via database SQL query.
|
| Constructor and Description |
|---|
HistoricalDataQueryStrategy(int myStreamNumber,
int historicalStreamNumber,
HistoricalEventViewable historicalEventViewable,
boolean isOuterJoin,
ExprEvaluator outerJoinCompareNode,
HistoricalIndexLookupStrategy indexLookupStrategy,
PollResultIndexingStrategy pollResultIndexingStrategy)
Ctor.
|
| Constructor and Description |
|---|
HistoricalDataExecNode(HistoricalEventViewable historicalEventViewable,
PollResultIndexingStrategy indexingStrategy,
HistoricalIndexLookupStrategy indexLookupStrategy,
int numStreams,
int historicalStreamNumber)
Ctor.
|
HistoricalTableLookupStrategy(HistoricalEventViewable viewable,
PollResultIndexingStrategy indexingStrategy,
HistoricalIndexLookupStrategy lookupStrategy,
int numStreams,
int streamNum,
int rootStreamNum,
ExprEvaluator outerJoinExprNode)
Ctor.
|