Package | Description |
---|---|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.support |
Internal-use-only services for unit and regression testing
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
com.espertech.esper.schedule |
Package for timer callback scheduling
|
Modifier and Type | Class and Description |
---|---|
class |
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
Modifier and Type | Field and Description |
---|---|
protected ThreadLocal<ArrayBackedCollection<ScheduleHandle>> |
EPRuntimeIsolatedImpl.scheduleArrayThreadLocal |
protected ThreadLocal<ArrayBackedCollection<ScheduleHandle>> |
EPRuntimeImpl.scheduleArrayThreadLocal |
Modifier and Type | Method and Description |
---|---|
void |
SchedulingServiceAudit.add(long afterMSec,
ScheduleHandle handle,
long slot) |
boolean |
SchedulingServiceAudit.isScheduled(ScheduleHandle handle) |
void |
SchedulingServiceAudit.remove(ScheduleHandle handle,
long slot) |
Modifier and Type | Method and Description |
---|---|
void |
SchedulingServiceAudit.evaluate(Collection<ScheduleHandle> handles) |
protected void |
EPRuntimeIsolatedImpl.processScheduleHandles(ArrayBackedCollection<ScheduleHandle> handles) |
void |
EPRuntimeImpl.processScheduleHandles(ArrayBackedCollection<ScheduleHandle> handles) |
Modifier and Type | Method and Description |
---|---|
Map<Long,ScheduleHandle> |
SupportSchedulingServiceImpl.getAdded() |
Modifier and Type | Method and Description |
---|---|
void |
SupportSchedulingServiceImpl.add(long afterTime,
ScheduleHandle callback,
long scheduleSlot) |
boolean |
SupportSchedulingServiceImpl.isScheduled(ScheduleHandle scheduleHandle) |
void |
SupportSchedulingServiceImpl.remove(ScheduleHandle callback,
long scheduleSlot) |
Modifier and Type | Method and Description |
---|---|
void |
SupportSchedulingServiceImpl.evaluate(Collection<ScheduleHandle> handles) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qScheduleAdd(long currentTime,
long afterMSec,
ScheduleHandle handle,
long slot) |
void |
Instrumentation.qScheduleAdd(long currentTime,
long afterMSec,
ScheduleHandle handle,
long slot) |
void |
InstrumentationDefault.qScheduleRemove(ScheduleHandle handle,
long slot) |
void |
Instrumentation.qScheduleRemove(ScheduleHandle handle,
long slot) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.aScheduleEval(Collection<ScheduleHandle> handles) |
void |
Instrumentation.aScheduleEval(Collection<ScheduleHandle> handles) |
Modifier and Type | Method and Description |
---|---|
ScheduleHandle |
ScheduleSetEntry.getHandle()
Returns the schedule handle.
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulingServiceImpl.add(long afterTime,
ScheduleHandle handle,
long slot) |
void |
SchedulingService.add(long afterMSec,
ScheduleHandle handle,
long scheduleSlot)
Add a callback for after the given milliseconds from the current time.
|
boolean |
SchedulingServiceImpl.isScheduled(ScheduleHandle handle) |
boolean |
SchedulingService.isScheduled(ScheduleHandle handle)
Returns true if the handle has been scheduled already.
|
void |
SchedulingServiceImpl.remove(ScheduleHandle handle,
long slot) |
void |
SchedulingService.remove(ScheduleHandle handle,
long scheduleSlot)
Remove a handle.
|
Modifier and Type | Method and Description |
---|---|
void |
SchedulingServiceImpl.evaluate(Collection<ScheduleHandle> handles) |
void |
SchedulingService.evaluate(Collection<ScheduleHandle> handles)
Evaluate the current time and add to the collection any handles scheduled for execution.
|
Constructor and Description |
---|
ScheduleSetEntry(Long time,
long scheduleSlot,
ScheduleHandle handle)
Ctor.
|