airflow/contrib/operators/cassandra_to_gcs.py
def convert_map_type(cls, name, value):
        """
        Converts a map to a repeated RECORD that contains two fields: 'key' and 'value',
        each will be converted to its corresponding data type in BQ.
        """
        converted_map = []
        for k, v in zip(value.keys(), value.values()):
            converted_map.append({
                'key': cls.convert_value('key', k),
                'value': cls.convert_value('value', v)
            })
        return converted_map
def convert_map_type(cls, name, value):
        """
        Converts a map to a repeated RECORD that contains two fields: 'key' and 'value',
        each will be converted to its corresponding data type in BQ.
        """
        converted_map = []
        for k, v in zip(value.keys(), value.values()):
            converted_map.append({
                'key': cls.convert_value('key', k),
                'value': cls.convert_value('value', v)
            })
        return converted_map
def convert_map_type ( cls , name , value ) : converted_map = [ ] for k , v in zip ( value . keys ( ) , value . values ( ) ) : converted_map . append ( { 'key' : cls . convert_value ( 'key' , k ) , 'value' : cls . convert_value ( 'value' , v ) } ) return converted_map
Converts a map to a repeated RECORD that contains two fields: 'key' and 'value',
        each will be converted to its corresponding data type in BQ.
Converts a map to a repeated RECORD that contains two fields : key and value each will be converted to its corresponding data type in BQ .