com.espertech.esper.common.internal.context.controller.initterm

Class ContextControllerInitTermUtil

java.lang.Object

com.espertech.esper.common.internal.context.controller.initterm.ContextControllerInitTermUtil

public class ContextControllerInitTermUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
ContextControllerInitTermUtil()

Method Summary

Modifier and Type	Method and Description
static ContextControllerInitTermPartitionKey	buildPartitionKey(EventBean optionalTriggeringEvent, Map<String,Object> optionalTriggeringPattern, ContextControllerCondition endCondition, ContextControllerInitTerm controller)
static long	computeScheduleMinimumDelta(ScheduleSpec[] schedules, long time, ClasspathImportServiceRuntime classpathImportService)
static long	computeScheduleMinimumNextOccurance(ScheduleSpec[] schedules, long time, ClasspathImportServiceRuntime classpathImportService)
static boolean	determineCurrentlyRunning(ContextControllerCondition startCondition, ContextControllerInitTerm controller)
static ContextControllerInitTermSvc	getService(ContextControllerInitTermFactory factory)
static ContextPartitionIdentifierInitiatedTerminated	keyToIdentifier(int subpathIdOrCPId, ContextControllerInitTermPartitionKey key, ContextControllerInitTerm controller)

Methods inherited from class java.lang.Object

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

Constructor Detail

ContextControllerInitTermUtil

public ContextControllerInitTermUtil()

Method Detail

getService

public static ContextControllerInitTermSvc getService(ContextControllerInitTermFactory factory)

determineCurrentlyRunning

public static boolean determineCurrentlyRunning(ContextControllerCondition startCondition,
                                                ContextControllerInitTerm controller)

buildPartitionKey

public static ContextControllerInitTermPartitionKey buildPartitionKey(EventBean optionalTriggeringEvent,
                                                                      Map<String,Object> optionalTriggeringPattern,
                                                                      ContextControllerCondition endCondition,
                                                                      ContextControllerInitTerm controller)

keyToIdentifier

public static ContextPartitionIdentifierInitiatedTerminated keyToIdentifier(int subpathIdOrCPId,
                                                                            ContextControllerInitTermPartitionKey key,
                                                                            ContextControllerInitTerm controller)

computeScheduleMinimumNextOccurance

public static long computeScheduleMinimumNextOccurance(ScheduleSpec[] schedules,
                                                       long time,
                                                       ClasspathImportServiceRuntime classpathImportService)

computeScheduleMinimumDelta

public static long computeScheduleMinimumDelta(ScheduleSpec[] schedules,
                                               long time,
                                               ClasspathImportServiceRuntime classpathImportService)