Add an ability to run Conformance on a streaming source
Đang mở
Conformance
feature
priority: medium
under discussion
- Ngôn ngữ chính
- Scala
- Star
- 33
- Fork
- 16
- Chỉ số merge pull request
- Không có pull request nào được merge trong 30 ngày
Mô tả
## Background
Add streaming support for Dynamic Conformance requires changes in the way we handle inputs, outputs and control measurements.
## Feature
Add initial support for running Conformance for a streaming source.
* Add command line parameters to identify that the job is streaming, specify the checkpoint location, etc.
* Change the way we load data to create dataframes.
* Change the way we save the output data.
Hướng dẫn đóng góp
Đánh giá
Issue này chưa được đánh giá.