...
Code Block | ||
---|---|---|
| ||
/// Tumnbling window tumbling = TIMEWINDOW({ size = [5, 'MINUTES'], advance = [5, 'MINUTES'] }, selectCenter ) /// Select firstlast of tumbling reduce = AGGREGATION({ aggregations = [['FUNCTION' = 'Last']], EVAL_AT_NEW_ELEMENT = false, EVAL_BEFORE_REMOVE_OUTDATING = true, group_by = ['movingObjectId'] }, tumbling ) /// Remove the grouping id (because it will be in the unnested tuple) withoutId = PROJECT({ attributes = ['last'] }, reduce ) /// Unnest the tuple output = UNNEST({ attribute='last' }, withoutId ) |
...