com.espertech.esper.runtime.internal.schedulesvcimpl

Class SchedulingServiceImpl

java.lang.Object

com.espertech.esper.runtime.internal.schedulesvcimpl.SchedulingServiceImpl

All Implemented Interfaces:

com.espertech.esper.common.internal.schedule.SchedulingService, com.espertech.esper.common.internal.schedule.TimeProvider, SchedulingServiceSPI

public final class SchedulingServiceImpl
extends Object
implements SchedulingServiceSPI

Implements the schedule service by simply keeping a sorted set of long millisecond values and a set of handles for each.

Synchronized since statement creation and event evaluation by multiple (event send) threads can lead to callbacks added/removed asynchronously.

Constructor Summary

Constructors

Constructor and Description
SchedulingServiceImpl(com.espertech.esper.common.internal.schedule.TimeSourceService timeSourceService) Constructor.

Method Summary

Modifier and Type	Method and Description
void	add(long afterTime, com.espertech.esper.common.internal.schedule.ScheduleHandle handle, long slot)
void	apply(ScheduleSet scheduleSet) Apply the set of schedules.
void	destroy()
void	evaluate(Collection<com.espertech.esper.common.internal.schedule.ScheduleHandle> handles)
Long	getFurthestTimeHandle()
String	getFurthestTimeHandleDate()
Long	getNearestTimeHandle()
String	getNearestTimeHandleDate()
int	getScheduleHandleCount()
long	getTime()
int	getTimeHandleCount()
void	init() Initialization is optional and provides a chance to preload things after statements are available.
boolean	isScheduled(com.espertech.esper.common.internal.schedule.ScheduleHandle handle)
void	remove(com.espertech.esper.common.internal.schedule.ScheduleHandle handle, long slot)
void	setTime(long currentTime)
ScheduleSet	take(Set<Integer> statementIds) Take a statement's schedules out of the currently active set of schedules.
void	visitSchedules(ScheduleVisitor visitor)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SchedulingServiceImpl

public SchedulingServiceImpl(com.espertech.esper.common.internal.schedule.TimeSourceService timeSourceService)

Constructor.

Parameters:

timeSourceService - time source provider

Method Detail

destroy

public void destroy()

Specified by:

destroy in interface com.espertech.esper.common.internal.schedule.SchedulingService

getTime

public long getTime()

Specified by:

getTime in interface com.espertech.esper.common.internal.schedule.TimeProvider

setTime

public final void setTime(long currentTime)

Specified by:

setTime in interface com.espertech.esper.common.internal.schedule.SchedulingService

add

public final void add(long afterTime,
                      com.espertech.esper.common.internal.schedule.ScheduleHandle handle,
                      long slot)
               throws com.espertech.esper.common.internal.schedule.ScheduleServiceException

Specified by:

add in interface com.espertech.esper.common.internal.schedule.SchedulingService

Throws:

com.espertech.esper.common.internal.schedule.ScheduleServiceException

remove

public final void remove(com.espertech.esper.common.internal.schedule.ScheduleHandle handle,
                         long slot)

Specified by:

remove in interface com.espertech.esper.common.internal.schedule.SchedulingService

evaluate

public final void evaluate(Collection<com.espertech.esper.common.internal.schedule.ScheduleHandle> handles)

Specified by:

evaluate in interface com.espertech.esper.common.internal.schedule.SchedulingService

take

public ScheduleSet take(Set<Integer> statementIds)

Description copied from interface: SchedulingServiceSPI

Take a statement's schedules out of the currently active set of schedules.

Specified by:

take in interface SchedulingServiceSPI

Parameters:

statementIds - statements to take out

Returns:

schedules

apply

public void apply(ScheduleSet scheduleSet)

Description copied from interface: SchedulingServiceSPI

Apply the set of schedules.

Specified by:

apply in interface SchedulingServiceSPI

Parameters:

scheduleSet - to apply

init

public void init()

Description copied from interface: SchedulingServiceSPI

Initialization is optional and provides a chance to preload things after statements are available.

Specified by:

init in interface SchedulingServiceSPI

getTimeHandleCount

public int getTimeHandleCount()

Specified by:

getTimeHandleCount in interface com.espertech.esper.common.internal.schedule.SchedulingService

getFurthestTimeHandleDate

public String getFurthestTimeHandleDate()

getNearestTimeHandleDate

public String getNearestTimeHandleDate()

getFurthestTimeHandle

public Long getFurthestTimeHandle()

Specified by:

getFurthestTimeHandle in interface com.espertech.esper.common.internal.schedule.SchedulingService

getScheduleHandleCount

public int getScheduleHandleCount()

Specified by:

getScheduleHandleCount in interface com.espertech.esper.common.internal.schedule.SchedulingService

isScheduled

public boolean isScheduled(com.espertech.esper.common.internal.schedule.ScheduleHandle handle)

Specified by:

isScheduled in interface com.espertech.esper.common.internal.schedule.SchedulingService

getNearestTimeHandle

public Long getNearestTimeHandle()

Specified by:

getNearestTimeHandle in interface SchedulingServiceSPI

visitSchedules

public void visitSchedules(ScheduleVisitor visitor)

Specified by:

visitSchedules in interface SchedulingServiceSPI