Package 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	Description
ContextControllerInitTermUtil()

Method Summary

Modifier and Type	Method	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 Details

ContextControllerInitTermUtil

public ContextControllerInitTermUtil()

Method Details

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)