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.common |
Aggregation services - common.
|
com.espertech.esper.epl.agg.service.groupby |
Aggregation services group-by regular
|
com.espertech.esper.epl.core.engineimport |
Engine import handling
|
com.espertech.esper.epl.datetime.calop |
Date-Time calendar operations.
|
com.espertech.esper.epl.datetime.dtlocal |
Date-time evaluators
|
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 |
Interval delta expression evaluation
|
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 |
---|---|
TimeAbacus |
AggregationMethodFactoryRate.getTimeAbacus() |
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) |
Modifier and Type | Method and Description |
---|---|
AggregationServiceFactoryForge |
AggregationServiceFactoryServiceImpl.getGroupBy(AggGroupByDesc aggGroupByDesc,
TimeAbacus timeAbacus,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactoryForge |
AggregationServiceFactoryService.getGroupBy(AggGroupByDesc aggGroupByDesc,
TimeAbacus timeAbacus,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
static AggregationServiceForgeDesc |
AggregationServiceFactoryFactory.getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
java.util.Map<ExprNode,java.lang.String> selectClauseNamedNodes,
java.util.List<ExprDeclaredNode> declaredExpressions,
ExprNode[] groupByNodes,
java.util.List<ExprAggregateNode> havingAggregateExprNodes,
java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
java.lang.annotation.Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
AggregationGroupByRollupDesc groupByRollupDesc,
java.lang.String optionalContextName,
IntoTableSpec intoTableSpec,
TableService tableService,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect,
EngineImportService engineImportService,
java.lang.String statementName,
TimeAbacus timeAbacus) |
Modifier and Type | Field and Description |
---|---|
protected TimeAbacus |
AggSvcGroupByForge.timeAbacus |
Modifier and Type | Method and Description |
---|---|
static void |
AggSvcGroupByReclaimAgedImpl.applyEnterCodegenSweep(CodegenMethodNode method,
CodegenClassScope classScope,
TimeAbacus timeAbacus) |
static long |
AggSvcGroupByReclaimAgedImpl.computeTimeReclaimAgeFreq(long current,
AggSvcGroupByReclaimAgedEvalFunc func,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
AggSvcGroupByForge(AggGroupByDesc aggGroupByDesc,
TimeAbacus timeAbacus) |
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,
java.math.MathContext optionalDefaultMathContext,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
ConfigurationEngineDefaults.ThreadingProfile threadingProfile,
java.util.Map<java.lang.String,java.lang.Object> transientConfiguration,
AggregationFactoryFactory aggregationFactoryFactory,
ConfigurationEngineDefaults.ByteCodeGeneration byteCodeGeneration,
java.lang.String engineURI,
CodegenCompiler codegenCompiler) |
Modifier and Type | Method and Description |
---|---|
static CalendarOpPlusFastAddResult |
CalendarOpPlusFastAddHelper.computeNextDue(long currentTime,
TimePeriod timePeriod,
java.util.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(java.util.List<CalendarOp> calendarOps,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalCalOpsLongForge(java.util.List<CalendarForge> calendarForges,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsIntervalEval(java.util.List<CalendarOp> calendarOps,
IntervalOp intervalOp,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsIntervalForge(java.util.List<CalendarForge> calendarForges,
IntervalForge intervalForge,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsReformatEval(java.util.List<CalendarOp> calendarOps,
ReformatOp reformatOp,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
DTLocalLongOpsReformatForge(java.util.List<CalendarForge> calendarForges,
ReformatForge reformatForge,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
DTLocalForge |
ExprDotDTForge.getForge(java.util.List<CalendarForge> calendarForges,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
java.lang.Class inputType,
EventType inputEventType,
ReformatForge reformatForge,
IntervalForge intervalForge) |
static ExprDotDTMethodDesc |
ExprDotDTFactory.validateMake(StreamTypeService streamTypeService,
java.util.Deque<ExprChainedSpec> chainSpecStack,
DatetimeMethodEnum dtMethod,
java.lang.String dtMethodName,
EPType inputType,
java.util.List<ExprNode> parameters,
ExprDotNodeFilterAnalyzerInput inputDesc,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
ExprDotDTForge(java.util.List<CalendarForge> calendarForges,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
ReformatForge reformatForge,
IntervalForge intervalForge,
java.lang.Class inputType,
EventType inputEventType) |
Modifier and Type | Method and Description |
---|---|
IntervalForge |
IntervalForgeFactory.getForge(StreamTypeService streamTypeService,
DatetimeMethodEnum method,
java.lang.String methodNameUsed,
java.util.List<ExprNode> parameters,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
static IntervalComputerForge |
IntervalComputerForgeFactory.make(DatetimeMethodEnum method,
java.util.List<ExprNode> expressions,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalForgeImpl(DatetimeMethodEnum method,
java.lang.String methodNameUse,
StreamTypeService streamTypeService,
java.util.List<ExprNode> expressions,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
IntervalDeltaExprTimePeriodNonConstForge(ExprTimePeriod timePeriod,
TimeAbacus timeAbacus) |
Modifier and Type | Method and Description |
---|---|
ReformatForge |
ReformatForgeFactory.getForge(EPType inputType,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus,
DatetimeMethodEnum method,
java.lang.String methodNameUsed,
java.util.List<ExprNode> parameters,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
ReformatEvalForge(CalendarEval calendarEval,
LocalDateTimeEval localDateTimeEval,
ZonedDateTimeEval zonedDateTimeEval,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatFormatForge(java.lang.Object formatter,
TimeAbacus timeAbacus) |
ReformatFormatToDateForge(java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatGetFieldForge(CalendarFieldEnum fieldNum,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
ReformatToCalendarForge(java.util.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(java.lang.Number timeInSeconds,
TimeAbacus timeAbacus) |
Constructor and Description |
---|
ExprTimePeriodEvalDeltaConstFactoryMsec(ExprEvaluator secondsEvaluator,
TimeAbacus timeAbacus) |
ExprTimePeriodEvalDeltaConstGivenCalAdd(ExprTimePeriodAdder.TimePeriodAdder[] adders,
int[] added,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus) |
ExprTimePeriodImpl(java.util.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,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
StatementSpecRaw spec,
ConfigurationInformation config,
TimeAbacus timeAbacus) |
static ExprTimePeriod |
ASTExprHelper.timePeriodGetExprJustSeconds(EsperEPL2GrammarParser.ExpressionContext expression,
java.util.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,
java.util.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,
java.util.TimeZone timeZone,
TimeAbacus timeAbacus)
Computes the next lowest date in milliseconds based on a specification and the
from-time passed in.
|