Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
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.datetime.calop |
Date-Time calendar operations.
|
com.espertech.esper.epl.datetime.eval |
Date-Time methods and related utility classes.
|
com.espertech.esper.epl.datetime.interval |
Interval algebra.
|
com.espertech.esper.epl.datetime.reformatop |
Date-Time re-formatting operations.
|
com.espertech.esper.epl.db |
Database SQL polling views and caches
|
com.espertech.esper.epl.expression.time |
Time-related expressions.
|
com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
com.espertech.esper.schedule |
Package for timer callback scheduling
|
Modifier and Type | Method and Description |
---|---|
TimeAbacus |
StatementContext.getTimeAbacus() |
Modifier and Type | Field and Description |
---|---|
protected TimeAbacus |
AggregationMethodFactoryRate.timeAbacus |
Modifier and Type | Method and Description |
---|---|
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeRate(StatementExtensionSvcContext statementExtensionSvcContext,
ExprRateAggNode exprRateAggNode,
boolean isEver,
long intervalTime,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
AggregationMethodFactory |
AggregationFactoryFactory.makeRate(StatementExtensionSvcContext statementExtensionSvcContext,
ExprRateAggNode exprRateAggNode,
boolean isEver,
long intervalMsec,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
AggregationMethodFactoryRate(ExprRateAggNode parent,
boolean isEver,
long intervalTime,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
AggSvcGroupByReclaimAgedImpl(ExprEvaluator[] evaluators,
AggregationMethodFactory[] aggregators,
AggregationAccessorSlotPair[] accessors,
AggregationStateFactory[] accessAggregations,
boolean join,
AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionMaxAge,
AggSvcGroupByReclaimAgedEvalFunc evaluationFunctionFrequency,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
TimeAbacus |
EngineImportServiceImpl.getTimeAbacus() |
TimeAbacus |
EngineImportService.getTimeAbacus() |
Constructor and Description |
---|
EngineImportServiceImpl(boolean allowExtendedAggregationFunc,
boolean isUdfCache,
boolean isDuckType,
boolean sortUsingCollator,
MathContext optionalDefaultMathContext,
TimeZone timeZone,
TimeAbacus timeAbacus,
ConfigurationEngineDefaults.ThreadingProfile threadingProfile,
Map<String,Object> transientConfiguration,
AggregationFactoryFactory aggregationFactoryFactory) |
Modifier and Type | Method and Description |
---|---|
static CalendarOpPlusFastAddResult |
CalendarOpPlusFastAddHelper.computeNextDue(long currentTime,
TimePeriod timePeriod,
Calendar reference,
TimeAbacus timeAbacus,
long remainder) |
Modifier and Type | Method and Description |
---|---|
com.espertech.esper.epl.datetime.eval.ExprDotEvalDT.DTLocalEvaluator |
ExprDotEvalDT.getEvaluator(List<CalendarOp> calendarOps,
TimeZone timeZone,
TimeAbacus timeAbacus,
Class inputType,
EventType inputEventType,
ReformatOp reformatOp,
IntervalOp intervalOp) |
static ExprDotEvalDTMethodDesc |
ExprDotEvalDTFactory.validateMake(StreamTypeService streamTypeService,
Deque<ExprChainedSpec> chainSpecStack,
DatetimeMethodEnum dtMethod,
String dtMethodName,
EPType inputType,
List<ExprNode> parameters,
ExprDotNodeFilterAnalyzerInput inputDesc,
TimeZone timeZone,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
ExprDotEvalDT(List<CalendarOp> calendarOps,
TimeZone timeZone,
TimeAbacus timeAbacus,
ReformatOp reformatOp,
IntervalOp intervalOp,
Class inputType,
EventType inputEventType) |
Modifier and Type | Method and Description |
---|---|
IntervalOp |
IntervalOpFactory.getOp(StreamTypeService streamTypeService,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
TimeZone timeZone,
TimeAbacus timeAbacus) |
static IntervalComputer |
IntervalComputerFactory.make(DatetimeMethodEnum method,
List<ExprNode> expressions,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalOpImpl(DatetimeMethodEnum method,
String methodNameUse,
StreamTypeService streamTypeService,
List<ExprNode> expressions,
TimeZone timeZone,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
ReformatOp |
ReformatOpFactory.getOp(TimeZone timeZone,
TimeAbacus timeAbacus,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters) |
Constructor and Description |
---|
ReformatOpEval(CalendarEval calendarEval,
LocalDateTimeEval localDateTimeEval,
ZonedDateTimeEval zonedDateTimeEval,
TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatOpGetField(CalendarFieldEnum fieldNum,
TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatOpToCalendar(TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatOpToDate(TimeZone timeZone,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
DataCacheExpiringImpl(double maxAgeSec,
double purgeIntervalSec,
ConfigurationCacheReferenceType cacheReferenceType,
SchedulingService schedulingService,
long scheduleSlot,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
TimeAbacus timeAbacus)
Ctor.
|
Modifier and Type | Class and Description |
---|---|
class |
TimeAbacusMicroseconds |
class |
TimeAbacusMilliseconds |
Modifier and Type | Method and Description |
---|---|
TimeAbacus |
ExprTimePeriodImpl.getTimeAbacus() |
Modifier and Type | Method and Description |
---|---|
static boolean |
ExprTimePeriodUtil.validateTime(Number timeInSeconds,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
ExprTimePeriodEvalDeltaConstFactoryMsec(ExprEvaluator secondsEvaluator,
TimeAbacus timeAbacus) |
ExprTimePeriodEvalDeltaConstGivenCalAdd(ExprTimePeriodImpl.TimePeriodAdder[] adders,
int[] added,
TimeZone timeZone,
TimeAbacus timeAbacus) |
ExprTimePeriodImpl(TimeZone timeZone,
boolean hasYear,
boolean hasMonth,
boolean hasWeek,
boolean hasDay,
boolean hasHour,
boolean hasMinute,
boolean hasSecond,
boolean hasMillisecond,
boolean hasMicrosecond,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprAllParams(EsperEPL2GrammarParser.TimePeriodContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
StatementSpecRaw spec,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprJustSeconds(EsperEPL2GrammarParser.ExpressionContext expression,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
static long |
ScheduleComputeHelper.computeDeltaNextOccurance(ScheduleSpec spec,
long afterTimeInMillis,
TimeZone timeZone,
TimeAbacus timeAbacus)
Computes the next lowest date in milliseconds based on a specification and the
from-time passed in and returns the delta from the current time.
|
static long |
ScheduleComputeHelper.computeNextOccurance(ScheduleSpec spec,
long afterTimeInMillis,
TimeZone timeZone,
TimeAbacus timeAbacus)
Computes the next lowest date in milliseconds based on a specification and the
from-time passed in.
|