-
Notifications
You must be signed in to change notification settings - Fork 5k
[Feature][Data Quality] DataQualityApplication Design #4829
Copy link
Copy link
Closed
Labels
Description
- Function
DataQualityApplication uses spark as execution engine and parse the input parameter to generate Connector、Executor and Writer .Read data from different data source through different Connector and use the sql in executor to operate data. Finally write the result into storage engine through the Writer - Architecture
- Parameter design
Parse input parameter to generate ConnectorParamters、ExecutorParameters and WriterParameters - Flow and DataQualityTask
- DataQualityTask is a interface, all the connectors、executors and writers must implement the DataQualityTask
- A Flow consist of a list of DataQualityTask
- The DataQualityApplication is to execute all DataQualityTask in Flow to complete the execution logic
- Parameter design
Reactions are currently unavailable