1c9f9302d3a556d1dcdc118fb3a58c6b007c717d,data-analytics/cloud-composer-examples/composer_http_post_example/spark_avg_speed.py,AverageSpeedEnhancer,dict_to_csv,#AverageSpeedEnhancer#Any#,57

Before Change

        Arguments:
            dictionary: A dictionary containing the data of interest.
        
        csv = ",".join([str(dictionary[key]) if dictionary.get(key) is not None else ""
                        for key in AverageSpeedEnhancer.output_schema])
        return csv

    def enhance_with_avg_speed(self, record):

After Change

        Arguments:
            dictionary: A dictionary containing the data of interest.
        
        with closing(cStringIO.StringIO()) as csv_string:
            writer = csv.DictWriter(csv_string, AverageSpeedEnhancer.output_schema)
            writer.writerow(dictionary)
            // Our desired output is a csv string not a line in a file so we strip the
            // newline character written by the writerow function by default.
            return csv_string.getvalue().strip()

    def enhance_with_avg_speed(self, record):
        
        This is the business logic for the average speed column to calculate for each record.
        The desired units are miles per hour.

Instances