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.dtlocal | |
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.interval.deltaexpr | |
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,
ConfigurationEngineDefaults.CodeGeneration codeGeneration,
String engineURI,
CodegenCompiler codegenCompiler) |
Modifier and Type | Method and Description |
---|---|
static CalendarOpPlusFastAddResult |
CalendarOpPlusFastAddHelper.computeNextDue(long currentTime,
TimePeriod timePeriod,
Calendar reference,
TimeAbacus timeAbacus,
long remainder) |
Modifier and Type | Field and Description |
---|---|
protected TimeAbacus |
DTLocalLongOpsReformatForge.timeAbacus |
protected TimeAbacus |
DTLocalLongOpsIntervalForge.timeAbacus |
protected TimeAbacus |
DTLocalCalOpsLongForge.timeAbacus |
Constructor and Description |
---|
DTLocalCalOpsLongEval(List<CalendarOp> calendarOps,
TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalCalOpsLongForge(List<CalendarForge> calendarForges,
TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsIntervalEval(List<CalendarOp> calendarOps,
IntervalOp intervalOp,
TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsIntervalForge(List<CalendarForge> calendarForges,
IntervalForge intervalForge,
TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsReformatEval(List<CalendarOp> calendarOps,
ReformatOp reformatOp,
TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsReformatForge(List<CalendarForge> calendarForges,
ReformatForge reformatForge,
TimeZone timeZone,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
DTLocalForge |
ExprDotDTForge.getForge(List<CalendarForge> calendarForges,
TimeZone timeZone,
TimeAbacus timeAbacus,
Class inputType,
EventType inputEventType,
ReformatForge reformatForge,
IntervalForge intervalForge) |
static ExprDotDTMethodDesc |
ExprDotDTFactory.validateMake(StreamTypeService streamTypeService,
Deque<ExprChainedSpec> chainSpecStack,
DatetimeMethodEnum dtMethod,
String dtMethodName,
EPType inputType,
List<ExprNode> parameters,
ExprDotNodeFilterAnalyzerInput inputDesc,
TimeZone timeZone,
TimeAbacus timeAbacus,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
ExprDotDTForge(List<CalendarForge> calendarForges,
TimeZone timeZone,
TimeAbacus timeAbacus,
ReformatForge reformatForge,
IntervalForge intervalForge,
Class inputType,
EventType inputEventType) |
Modifier and Type | Method and Description |
---|---|
IntervalForge |
IntervalForgeFactory.getForge(StreamTypeService streamTypeService,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
TimeZone timeZone,
TimeAbacus timeAbacus) |
static IntervalComputerForge |
IntervalComputerForgeFactory.make(DatetimeMethodEnum method,
List<ExprNode> expressions,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalForgeImpl(DatetimeMethodEnum method,
String methodNameUse,
StreamTypeService streamTypeService,
List<ExprNode> expressions,
TimeZone timeZone,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalDeltaExprTimePeriodNonConstForge(ExprTimePeriod timePeriod,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
ReformatForge |
ReformatForgeFactory.getForge(EPType inputType,
TimeZone timeZone,
TimeAbacus timeAbacus,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
ReformatEvalForge(CalendarEval calendarEval,
LocalDateTimeEval localDateTimeEval,
ZonedDateTimeEval zonedDateTimeEval,
TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatFormatForge(Object formatter,
TimeAbacus timeAbacus) |
ReformatFormatToDateForge(TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatGetFieldForge(CalendarFieldEnum fieldNum,
TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatToCalendarForge(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() |
TimeAbacus |
ExprTimePeriodForge.getTimeAbacus() |
Modifier and Type | Method and Description |
---|---|
static boolean |
ExprTimePeriodUtil.validateTime(Number timeInSeconds,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
ExprTimePeriodEvalDeltaConstFactoryMsec(ExprEvaluator secondsEvaluator,
TimeAbacus timeAbacus) |
ExprTimePeriodEvalDeltaConstGivenCalAdd(ExprTimePeriodAdder.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.
|