Raw_layer_validation
This is a mini Pyspark project maintaining the integrity of the Metadata.
This code can be used further to extend ETL functionality,other dependency checks like using it for database connections etc.
- it checks the number of columns ,column name and column datatype are matching with the source schema to metaschema.
- if column count dosent matches then the code will fail to write the job to the target location.
Note:here MetaSchema is a json file which consists of column name and and its dataype defined by you inorder to validate with the respective source file schema