Add support for slowly changing mapping tables
未关闭
Conformance
feature
priority: medium
under discussion
- 主要语言
- Scala
- 星标
- 33
- 派生
- 16
- PR 合并指标
- 30 天内没有已合并 PR
描述
## Background
Streaming conformance currently uses static mapping tables read from HDFS.
If a job is running long enough the mapping tables become outdated.
## Feature
Long-running streaming conformance jobs need a way to make in-memory mapping tables up to date.
Not sure yet how to pick up the changes to mapping tables.
- [ ] Periodically check the HDFS folder with mapping tables for updates
- [ ] Subscribe to a Kafka topic with changes to mapping tables
Which way to go depends on how MDM and MDR are done.
贡献指南
评估
这个 Issue 还没有评估数据。