Package com.espertech.esper.common.internal.schedule

Class ScheduleBucket

java.lang.Object
com.espertech.esper.common.internal.schedule.ScheduleBucket
public class ScheduleBucket extends Object
This class acts as a buckets for sorting schedule service callbacks that are scheduled to occur at the same time. Each buckets constists of slots that callbacks are assigned to.

At the time of timer evaluation, callbacks that become triggerable are ordered using the bucket as the first-level order, and slot as the second-level order.

Each statement at statement creation time allocates a buckets, and each timer within the statement allocates a slot. Thus statements that depend on other statements (such as for insert-into), and timers within their statement (such as time window or output rate limit timers) behave deterministically.

  • Constructor Details

    • ScheduleBucket

      public ScheduleBucket(int statementId)
      Ctor.
      Parameters:
      statementId - is the statement id

  • Method Details

    • allocateSlot

      public long allocateSlot()

    • allocateSlot

      public long allocateSlot(int slotNumber)

    • toLong

      public static long toLong(int bucket, int slot)