influxdata / influxdata/kapacitor

Add support for continuous queries offset interval

Open
#1,824 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Go
Stars
2.4k
Forks
479
Avg merge
4d 16h
Merged PRs (30d)
4

Description

Currently there is no way (with WindowNode) to specify an offset interval to alter the CQ’s default execution time.

```
stream
|window()
.period(1h)
.every(1h)
.align()
```

```
CREATE CONTINUOUS QUERY "cq_basic_offset" ON "transportation"
BEGIN
SELECT mean("passengers") INTO "average_passengers" FROM "bus_data" GROUP BY time(1h,15m)
END
```

Contributor guide

Open the contributing guide

Research direction

Start by tracing the WindowNode handling and continuous-query execution path referenced in the issue, then compare the provided .align() and GROUP BY time(1h,15m) examples. Determine where an offset interval would be represented and applied, and add coverage showing that the continuous query executes at the requested offset.

Written by the indexing model from the issue text.

Assessment

Tech stack
go
Domain
stream-processing
Issue type
Feature
Difficulty
4/5
Estimated time
3-5 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
35/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.