Add change streams to tables
- Dominant language
- Java
- Stars
- 6.1k
- Forks
- 1.5k
- Avg merge
- 2d 55m
- Merged PRs (30d)
- 182
Description
Add a feature that is similar to Postgres WAL or mongo change streams that would allow subscribing to change events on a table.
This would allow for event driven dashboard updates as new events arrive. It would be useful to also include a filter option similar to mongo change streams where a predicate option can be passed to filter on only the events of intrest.
Currently, to achieve event driven updates, the original data source needs to be monitored for changes or continuously poll query pinot to see if max(timestamp) has changed or some other similar solution.
Slack conversation: https://apache-pinot.slack.com/archives/C01H1S9J5BJ/p1680724008970809
Contributor guide
Research direction
The payload names no files, tests, or entry points. Begin with the linked Slack conversation and clarify the intended table events, subscription behavior, predicate filtering, and delivery guarantees; done is an agreed design with validation criteria.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- databases, distributed-systems
- Issue type
- Feature
- Difficulty
- 5/5
- Estimated time
- Over a week
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100