influxdata / influxdata/kapacitor
Feature request: make nodes recognize the 'time' value
- Dominant language
- Go
- Stars
- 2.4k
- Forks
- 479
- Avg merge
- 4d 16h
- Merged PRs (30d)
- 4
Description
Hi,
I couldn't not find how to make nodes like `changeDetect(field string)` or functions like `distinct(field string)` take the time into account.
Can we support the special 'time' value who would pick it out from the time?
I understand this would be an issue if someone sends data with 'time' in the fields.
My use-case is deduplicating data when using influx-relay and influxdb subscriptions: every influxdb instance sends data to the same kapacitor, which receives data multiple times.
Counts like stateCount get messed up by the duplicate data.
Best,
Anthony
Contributor guide
Research direction
Begin at the changeDetect(field string) and distinct(field string) entry points named in the issue, then trace how fields are selected. Done means the special 'time' value is recognized for these operations and duplicate InfluxDB points in the stated use case are handled without breaking ordinary fields.
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