店铺增加 历史星级数据字段 feedback_histogram

Pyspark_job/sqoop_import/ods_seller_account_feedback.py

@@ -34,7 +34,8 @@ if __name__ == '__main__':
             created_at,
             updated_at,
             regexp_replace(seller_address, E'[\\r\\n\\t]+', ' ', 'g') as seller_address,
-            regexp_replace(seller_rating,  E'[\\r\\n\\t]+', ' ', 'g') as seller_rating
+            regexp_replace(seller_rating,  E'[\\r\\n\\t]+', ' ', 'g') as seller_rating,
+            regexp_replace(feedback_histogram,  E'[\\r\\n\\t]+', ' ', 'g') as feedback_histogram
         from {import_table} 
         where 1=1
         and \$CONDITIONS