def testNoTransform(self):
    config = {
        'sinks': [
            '/bucket/output_file',
            '/bucket/output_file_badrows'
        ],
        'fieldDelimiter': ',',
        'sources': [
            'input-file'
        ],
        'skipLeadingRows': 1,
        'type': 'Data Pipeline',
        'columns': [
            {
                'wanted': True,
                'type': 'STRING',
                'name': 'Name',
                'transformations': []
            },
            {
                'wanted': True,
                'type': 'INTEGER',
                'name': 'Number',
                'transformations': []
            }
        ]
    }

    input_file = cStringIO.StringIO('abc,1\ndef,2\n')
    output_file = cStringIO.StringIO()

    csv_transformer_mapper_tmpl.Transform(
        json.dumps(config), input_file, output_file)

    self.assertEqual('abc,1\ndef,2\n', output_file.getvalue())
Tests no-op transformation.
dataset/ETHPy150Open GoogleCloudPlatform/Data-Pipeline/app/src/hadoop/csv_transformer_mapper_tmpl_test.py/TransformTest.testNoTransform