def run(self, config):
    transformer = hadoop_csv_transformer.HadoopCsvTransformer(config)
    transformer.StartTransform()
Initiate Hadoop MapReduce for CSV transformation.
dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/src/pipelines/stages/hadoopcsvmatchreplace.py/HadoopCsvMatchReplace.run