Uploaded image for project: 'Edgent'
  1. Edgent
  2. EDGENT-231

Add tuple-event-time ordered time-based windows

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Open
    • Major
    • Resolution: Unresolved
    • None
    • None
    • API
    • None

    Description

      TStream.last(period,unit,keyFn) creates an insertion-time time-based TWindow - a tuple's timestamp, hence its lifetime in the time-based window, is based on the time it is inserted into the window.

      On a couple of occasions some folks have asked about event-time time-based windows - a tuple's timestamp (event-time) is present as a property in the tuple and that timestamp is used for insertion and eviction processing. Tuples need not be added to the window in their event-time order though the partition contents are maintained in event-time order.

      The TStream API for such a time-based window could be:
      ```
      <K> TWindow<T, K> last(long time, TimeUnit unit, Function<T, K> keyFunction, ToLongFunction<T> timestampFn);
      ```

      See also: QUARKS-230

      Attachments

        Activity

          People

            Unassigned Unassigned
            dlaboss Dale LaBossiere
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: